diff --git a/clearml/backend_interface/task/task.py b/clearml/backend_interface/task/task.py index dfb3f03b..3fbc8674 100644 --- a/clearml/backend_interface/task/task.py +++ b/clearml/backend_interface/task/task.py @@ -553,10 +553,13 @@ class Task(IdObjectBase, AccessMixin, SetupUploadMixin): """ The signal that this Task started. """ return self.send(tasks.StartedRequest(self.id, force=force), ignore_errors=ignore_errors) - def stopped(self, ignore_errors=True, force=False): - # type: (bool, bool) -> () + def stopped(self, ignore_errors=True, force=False, status_reason=None): + # type: (bool, bool, Optional[str]) -> () """ The signal that this Task stopped. """ - return self.send(tasks.StoppedRequest(self.id, force=force), ignore_errors=ignore_errors) + return self.send( + tasks.StoppedRequest(self.id, force=force, status_reason=status_reason), + ignore_errors=ignore_errors + ) def completed(self, ignore_errors=True): # type: (bool) -> () diff --git a/clearml/task.py b/clearml/task.py index daac450e..f1e86968 100644 --- a/clearml/task.py +++ b/clearml/task.py @@ -2883,7 +2883,7 @@ class Task(_Task): ) ) self.flush(wait_for_uploads=True) - self.stopped() + self.stopped(status_reason='USER ABORTED') if self._dev_worker: self._dev_worker.unregister()