Loading transfer_service/import_executor.py +15 −15 Original line number Diff line number Diff line Loading @@ -288,7 +288,7 @@ class ImportExecutor(TaskExecutor): else: self.update("ERROR") try: if destQueueLen == self.maxTerminatedJobs: if destQueueLen >= self.maxTerminatedJobs: self.destQueue.extractJob() self.destQueue.insertJob(self.jobObj) self.srcQueue.extractJob() Loading Loading
transfer_service/import_executor.py +15 −15 Original line number Diff line number Diff line Loading @@ -288,7 +288,7 @@ class ImportExecutor(TaskExecutor): else: self.update("ERROR") try: if destQueueLen == self.maxTerminatedJobs: if destQueueLen >= self.maxTerminatedJobs: self.destQueue.extractJob() self.destQueue.insertJob(self.jobObj) self.srcQueue.extractJob() Loading