diff --git a/trains_agent/commands/worker.py b/trains_agent/commands/worker.py index f489c44..e1fb92e 100644 --- a/trains_agent/commands/worker.py +++ b/trains_agent/commands/worker.py @@ -263,7 +263,7 @@ class TaskStopSignal(object): ) return TaskStopReason.stopped - if status in self.unexpected_statuses and "worker" not in message: + if status in self.unexpected_statuses: ## and "worker" not in message: self.command.log("unexpected status change, task will terminate") return TaskStopReason.status_changed