Skip to content

Commit

Permalink
Fixed problem when running runner document is not yet in the auxiliary
Browse files Browse the repository at this point in the history
collection.
  • Loading branch information
davidwaroquiers committed Jul 18, 2024
1 parent 2c393e9 commit 281e710
Showing 1 changed file with 1 addition and 4 deletions.
5 changes: 1 addition & 4 deletions src/jobflow_remote/jobs/daemon.py
Original file line number Diff line number Diff line change
Expand Up @@ -420,14 +420,11 @@ def start(
) -> bool:
db_filter = {"running_runner": {"$exists": True}}
with self.job_controller.lock_auxiliary(filter=db_filter) as lock:
if lock is None:
# print('Handle case where the document is not present!')
pass
if lock.is_locked:
# print('Handle case where the document is locked')
pass
doc = lock.locked_document
if doc["running_runner"] is not None:
if doc and doc["running_runner"] is not None:
# print('Handle case where there is a "registered" running runner in the auxiliary collection')
pass
status = self.check_status()
Expand Down

0 comments on commit 281e710

Please sign in to comment.