diff --git a/distributask/distributask.py b/distributask/distributask.py index 6e0e6ae..192f74f 100644 --- 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: """