def METHOD_NAME(self, rcfg, pilot):
    schema = self._get_schema(rcfg)
    if not schema:
        return False
    if schema not in self._jex:
        self._log.debug('create executor for %s', schema)
        try:
            self._jex[schema] = psij.JobExecutor.get_instance(schema)
            self._jex[schema].set_job_status_callback(self._job_status_cb)
        except:
            self._log.exception('failed to create psij executor')
            return False
    return True