fix: Retry task only if it's an Arq task (#1640)

keephq · Aug 20, 2024 · 95a2bed · 95a2bed
1 parent ddba734
commit 95a2bed
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/keep/api/tasks/process_event_task.py b/keep/api/tasks/process_event_task.py
@@ -472,7 +472,9 @@ def process_event(
         )
     except Exception:
         logger.exception("Error processing event", extra=extra_dict)
-        raise Retry(defer=ctx["job_try"] * TIMES_TO_RETRY_JOB)
+        # Retrying only if context is present (running the job in arq worker)
+        if bool(ctx):
+            raise Retry(defer=ctx["job_try"] * TIMES_TO_RETRY_JOB)
     finally:
         session.close()
     logger.info("Event processed", extra=extra_dict)