diff --git a/queue_job/jobrunner/runner.py b/queue_job/jobrunner/runner.py index 21f2919349..8e755676e8 100644 --- a/queue_job/jobrunner/runner.py +++ b/queue_job/jobrunner/runner.py @@ -572,7 +572,7 @@ def keep_alive_shared_lock(self): self.shared_lock_db.keep_alive() def _lock_ident(self): - return "-".join(sorted(self.list_db_names)) + return "qj:{}".format("-".join(sorted(self.list_db_names))) def stop(self): _logger.info("graceful stop requested")