From aaa9585d002d6d6ff89e23ccbf51a75325471c6c Mon Sep 17 00:00:00 2001
From: Nikita Zavadin <nikita.zavadin@wolt.com>
Date: Tue, 26 Nov 2024 13:22:24 +0100
Subject: [PATCH] Add comment

---
 arq/worker.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/arq/worker.py b/arq/worker.py
index 8572afb3..8fcd5fc8 100644
--- a/arq/worker.py
+++ b/arq/worker.py
@@ -449,6 +449,8 @@ async def start_jobs(self, job_ids: List[bytes]) -> None:
                 score = await pipe.zscore(self.queue_name, job_id)
                 if ongoing_exists or not score or score > timestamp_ms():
                     # job already started elsewhere, or already finished and removed from queue
+                    # if score > ts_now,
+                    # it means probably the job was re-enqueued with a delay in another worker
                     self.job_counter = self.job_counter - 1
                     self.sem.release()
                     logger.debug('job %s already running elsewhere', job_id)