From 50d620cc9ac66273a89c40c45caeaa50f027ba11 Mon Sep 17 00:00:00 2001
From: allegroai <>
Date: Mon, 12 Apr 2021 22:56:33 +0300
Subject: [PATCH] Add force argument to Task.mark_failed()

---
 clearml/backend_interface/task/task.py | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/clearml/backend_interface/task/task.py b/clearml/backend_interface/task/task.py
index 05f1ec48..4a76f37e 100644
--- a/clearml/backend_interface/task/task.py
+++ b/clearml/backend_interface/task/task.py
@@ -555,11 +555,14 @@ class Task(IdObjectBase, AccessMixin, SetupUploadMixin):
             return self.send(tasks.CompletedRequest(self.id, status_reason='completed'), ignore_errors=ignore_errors)
         return self.send(tasks.StoppedRequest(self.id, status_reason='completed'), ignore_errors=ignore_errors)
 
-    def mark_failed(self, ignore_errors=True, status_reason=None, status_message=None):
-        # type: (bool, Optional[str], Optional[str]) -> ()
+    def mark_failed(self, ignore_errors=True, status_reason=None, status_message=None, force=False):
+        # type: (bool, Optional[str], Optional[str], bool) -> ()
         """ The signal that this Task stopped. """
-        return self.send(tasks.FailedRequest(self.id, status_reason=status_reason, status_message=status_message),
-                         ignore_errors=ignore_errors)
+        return self.send(
+            tasks.FailedRequest(
+                task=self.id, status_reason=status_reason, status_message=status_message, force=force),
+            ignore_errors=ignore_errors,
+        )
 
     def publish(self, ignore_errors=True):
         # type: (bool) -> ()