remove retry if exception is raised

DeepAI-Research · Aug 13, 2024 · 00f42e3 · 00f42e3
1 parent 321a455
commit 00f42e3
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/distributask/distributask.py b/distributask/distributask.py
@@ -231,9 +231,8 @@ def call_function_task(self, func_name: str, args_json: str) -> any:
             return result
         except Exception as e:
             self.log(f"Error in call_function_task: {str(e)}", "error")
-            self.call_function_task.retry(exc=e)
+            # self.call_function_task.retry(exc=e)
 
-        return result
 
     def register_function(self, func: callable) -> callable:
         """