Merge pull request #93 from DeepAI-Research/antbaez/fixing_issues

remove retry if exception is raised
DeepAI-Research · Aug 13, 2024 · f7ba1b7 · f7ba1b7
2 parents 6d7ddfa + 00f42e3
commit f7ba1b7
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:
         """