We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6f88b31 commit f0da3f7Copy full SHA for f0da3f7
1 file changed
queue_job/jobrunner/runner.py
@@ -433,7 +433,11 @@ def close_databases(self, remove_jobs=True):
433
def initialize_databases(self):
434
for db_name in sorted(self.get_db_names()):
435
# sorting is important to avoid deadlocks in acquiring the master lock
436
- db = Database(db_name)
+ try:
437
+ db = Database(db_name)
438
+ except Exception as e:
439
+ _logger.warning(e)
440
+ continue
441
if db.has_queue_job:
442
self.db_by_name[db_name] = db
443
with db.select_jobs("state in %s", (NOT_DONE,)) as cr:
0 commit comments