Add check for jobs without dependencies

This commit is contained in:
Ethan Wolinsky 2023-05-08 21:40:53 -04:00
parent 0fe114e45e
commit b03413e9eb
1 changed files with 2 additions and 0 deletions

View File

@ -10,6 +10,8 @@ class Dependency:
pipe = pipeline if pipeline else cls.connection
ready_jobs = []
for job in jobs:
if not job._dependency_ids:
pass
while True:
try:
pipe.watch(*[Job.key_for(dependency_id) for dependency_id in job._dependency_ids])