fix(jobs): use NOW(3) to match CURRENT_TIMESTAMP(3) precision

The scheduled_time column uses CURRENT_TIMESTAMP(3) with milliseconds,
so comparisons must also use NOW(3) for consistent precision.

Co-Authored-By: Claude Opus 4.5 <[email protected]>

Author: dimitri-yatsenko

src/datajoint/autopopulate.py

@@ -487,8 +487,8 @@ def handler(signum, frame):
             if refresh:
                 self.jobs.refresh(*restrictions, priority=priority)
 
-            # Fetch pending jobs ordered by priority
-            pending_query = self.jobs.pending & "scheduled_time <= NOW()"
+            # Fetch pending jobs ordered by priority (use NOW(3) to match CURRENT_TIMESTAMP(3) precision)
+            pending_query = self.jobs.pending & "scheduled_time <= NOW(3)"
             if priority is not None:
                 pending_query = pending_query & f"priority <= {priority}"
 

src/datajoint/jobs.py

@@ -447,8 +447,8 @@ def reserve(self, key: dict) -> bool:
         bool
             True if reservation successful, False if job not available.
         """
-        # Check if job is pending and scheduled (use MySQL NOW() for consistent timing)
-        job = (self & key & 'status="pending"' & "scheduled_time <= NOW()").to_dicts()
+        # Check if job is pending and scheduled (use NOW(3) to match CURRENT_TIMESTAMP(3) precision)
+        job = (self & key & 'status="pending"' & "scheduled_time <= NOW(3)").to_dicts()
 
         if not job:
             return False