def METHOD_NAME(self, rcfg, pilots):
    assert psij
    for pilot in pilots:
        pid    = pilot['uid']
        schema = self._get_schema(rcfg)
        assert schema
        jex = self._jex.get(schema)
        assert jex
        jd = pilot['jd_dict']
        proj, res = None, None
        if jd.project:
            if ':' in jd.project:
                proj, res = jd.project.split(':', 1)
            else:
                proj = jd.project
        attr = psij.JobAttributes()
        attr.duration       = jd.wall_time_limit
        attr.queue_name     = jd.queue
        attr.project_name   = proj
        attr.reservation_id = res
        spec = psij.JobSpec()
        spec.attributes  = attr
        spec.executable  = jd.executable
        spec.arguments   = jd.arguments
        spec.environment = jd.environment
        spec.directory   = jd.working_directory
        spec.stdout_path = jd.output
        spec.stderr_path = jd.error
        spec.resources   = psij.ResourceSpecV1()
        spec.resources.node_count            = jd.node_count
        spec.resources.process_count         = jd.total_cpu_count
      # spec.resources.cpu_cores_per_process = 1
      # spec.resources.gpu_cores_per_process = jd.total_gpu_count
        job = psij.Job(spec)
        self._jobs[pid]      = job
        self._pilots[job.id] = pilot
        self._log.debug('added %s: %s', job.id, pid)
        jex.submit(job)