fix: add retries

cognee/modules/pipelines/operations/run_tasks_distributed.py

@@ -25,6 +25,7 @@ if modal:
     from distributed.modal_image import image
 
     @app.function(
+        retries=3,
         image=image,
         timeout=86400,
         max_containers=50,

distributed/workers/data_point_saving_worker.py

@@ -40,6 +40,7 @@ def is_deadlock_error(error):
 
 
 @app.function(
+    retries=3,
     image=image,
     timeout=86400,
     max_containers=5,

distributed/workers/graph_saving_worker.py

@@ -38,6 +38,7 @@ def is_deadlock_error(error):
 
 
 @app.function(
+    retries=3,
     image=image,
     timeout=86400,
     max_containers=5,