We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 09f433f commit 20db518Copy full SHA for 20db518
1 file changed
executor/eventloop.go
@@ -100,7 +100,8 @@ func sendFailedTasks(state *internalState) {
100
delete(state.failedTasks, taskID)
101
// If there aren't any failed and active tasks, we request to shutdown the executor.
102
if len(state.failedTasks) == 0 && len(state.activeTasks) == 0 {
103
- state.shouldQuit = true
+ //Originally state.shouldQuit = true but we want to keep the executor running
104
+ log.WithField("executorId", state.executor.ExecutorID).Info("task failure notified, no tasks present on executor")
105
}
106
107
0 commit comments