Skip to content

Commit 50c1276

Browse files
committed
updated watchRetailedResults function
1 parent f7fa465 commit 50c1276

1 file changed

Lines changed: 8 additions & 5 deletions

File tree

compute_worker/compute_worker.py

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -474,7 +474,7 @@ async def watch_detailed_results(self):
474474
start = time.time()
475475
expiration_seconds = 60
476476

477-
while self.watch and self.completed_program_counter < 2:
477+
while self.watch and self.completed_program_counter < 1:
478478
if file_path:
479479
new_time = os.path.getmtime(file_path)
480480
if new_time != last_modified_time:
@@ -1499,9 +1499,9 @@ def start(self):
14991499
)
15001500

15011501
# During scoring we watch for detailed results
1502-
# tasks.append(
1503-
# self.watch_detailed_results()
1504-
# )
1502+
tasks.append(
1503+
self.watch_detailed_results()
1504+
)
15051505
else:
15061506
# During ingestion we run ingestion program directory and submission directory
15071507
tasks.extend([
@@ -1623,7 +1623,10 @@ def start(self):
16231623

16241624
if self.is_scoring:
16251625
# Check if scoring program failed
1626-
program_results, _, _ = task_results
1626+
try:
1627+
program_results, _, _ = task_results
1628+
except:
1629+
program_results, _ = task_results
16271630
# Gather returns either normal values or exception instances when return_exceptions=True
16281631
had_async_exc = isinstance(
16291632
program_results, BaseException

0 commit comments

Comments
 (0)