diff --git a/pilot/control/job.py b/pilot/control/job.py index d01d9b45..f9b80c25 100644 --- a/pilot/control/job.py +++ b/pilot/control/job.py @@ -2365,7 +2365,7 @@ def create_job(dispatcher_response: dict, queuename: str) -> Any: job = JobData(dispatcher_response) jobinfosys = InfoService() jobinfosys.init(queuename, infosys.confinfo, infosys.extinfo, JobInfoProvider(job)) - job.init(infosys) + job.init(jobinfosys) logger.info(f'received job: {job.jobid} (sleep until the job has finished)')