[IMP] queue_job: handle same uuid in duplicated db

Author: hoangtrann

queue_job/jobrunner/channels.py

@@ -1029,22 +1029,31 @@ def notify(
         channel = self.get_channel_by_name(channel_name, parent_fallback=True)
         job = self._jobs_by_uuid.get(uuid)
         if job:
-            # db_name is invariant
-            assert job.db_name == db_name
-            # date_created is invariant
-            assert job.date_created == date_created
-            # if one of the job properties that influence
-            # scheduling order has changed, we remove the job
-            # from the queues and create a new job object
-            if (
-                seq != job.seq
-                or priority != job.priority
-                or eta != job.eta
-                or channel != job.channel
-            ):
-                _logger.debug("job %s properties changed, rescheduling it", uuid)
+            # if db_name differs, this is likely a cloned database
+            if job.db_name != db_name:
+                _logger.warning(
+                    "job %s exists in multiple databases (%s and %s). recreating it",
+                    uuid,
+                    job.db_name,
+                    db_name,
+                )
                 self.remove_job(uuid)
                 job = None
+            else:
+                # date_created is invariant
+                assert job.date_created == date_created
+                # if one of the job properties that influence
+                # scheduling order has changed, we remove the job
+                # from the queues and create a new job object
+                if (
+                    seq != job.seq
+                    or priority != job.priority
+                    or eta != job.eta
+                    or channel != job.channel
+                ):
+                    _logger.debug("job %s properties changed, rescheduling it", uuid)
+                    self.remove_job(uuid)
+                    job = None
         if not job:
             job = ChannelJob(db_name, channel, uuid, seq, date_created, priority, eta)
             self._jobs_by_uuid[uuid] = job