diff --git a/iceprod/server/plugins/condor.py b/iceprod/server/plugins/condor.py index ba96f154..7850c89e 100644 --- a/iceprod/server/plugins/condor.py +++ b/iceprod/server/plugins/condor.py @@ -401,7 +401,7 @@ def save_timestamp(self): async def run(self, forever=True): # initial job load from JELs try: - await self.wait(timeout=0, reload_jobs=True) + await self.wait(timeout=0) except Exception: logger.warning('failed to wait', exc_info=True) @@ -491,13 +491,12 @@ def get_current_JEL(self) -> Path: # JEL processing # - async def wait(self, timeout, reload_jobs=False): + async def wait(self, timeout): """ Wait for jobs to complete from the Job Event Logs. Args: timeout: wait up to N seconds - reload_jobs: accept unknown jobs """ start = time.monotonic() @@ -516,13 +515,10 @@ async def wait(self, timeout, reload_jobs=False): if event.type == htcondor.JobEventType.SUBMIT: self.jobs[job_id] = CondorJob() continue - elif reload_jobs and job_id not in self.jobs: + elif job_id not in self.jobs: logger.debug('reloaded job %s', job_id) self.jobs[job_id] = CondorJob() - if job_id not in self.jobs: - logger.warning('unknown job: %s', job_id) - continue job = self.jobs[job_id] if event.type == htcondor.JobEventType.JOB_AD_INFORMATION: