We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d355d58 commit 6a1733dCopy full SHA for 6a1733d
1 file changed
compute_worker/compute_worker.py
@@ -520,6 +520,8 @@ async def watch_detailed_results(self):
520
start = time.time()
521
expiration_seconds = 60
522
523
+ # When running scoring program, we have at least one program to run i.e. scoring_program
524
+ # Sometimes when ingestion_only_during_scoring is True, we have two programs to run
525
expected_completed_program_counters = 1 + int(bool(self.ingestion_only_during_scoring))
526
while self.watch and self.completed_program_counter < expected_completed_program_counters:
527
if file_path:
0 commit comments