Skip to content

Commit 17b8bc1

Browse files
authored
Merge pull request #5638 from chrisburr/more-executor
[v7r2] More executor fixes
2 parents ae43f4b + bb05b6b commit 17b8bc1

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/DIRAC/Core/Utilities/ExecutorDispatcher.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -826,14 +826,14 @@ def __sendTaskToExecutor(self, eId, eTypes=False, checkIdle=False):
826826
self.__msgTaskToExecutor(taskId, eId, eType)
827827
except UnrecoverableTaskException as e:
828828
self.__log.exception("Failed to call __msgTaskToExecutor for", taskId)
829+
self.__states.removeTask(taskId)
829830
return S_ERROR(str(e))
830831
except Exception:
831832
self.__log.exception("Exception while sending task to executor")
832833
self.__queues.pushTask(eType, taskId, ahead=False)
833834
self.__states.removeTask(taskId)
834835
return S_ERROR("Exception while sending task to executor")
835-
else:
836-
return S_OK(taskId)
836+
return S_OK(taskId)
837837

838838
def __msgTaskToExecutor(self, taskId, eId, eType):
839839
try:

0 commit comments

Comments
 (0)