Skip to content

Commit 9a726fe

Browse files
committed
RUNNING status during ingestion
1 parent 81925b8 commit 9a726fe

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

compute_worker/compute_worker.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1226,9 +1226,8 @@ def prepare(self):
12261226
if self.is_scoring:
12271227
self._update_status(SubmissionStatus.RUNNING, extra_information=f"scoring_hostname-{hostname}")
12281228
else:
1229-
self._update_status(SubmissionStatus.RUNNING, extra_information=f"ingestion_hostname-{hostname}")
12301229
# Only during prediction step do we want to announce "preparing"
1231-
self._update_status(SubmissionStatus.PREPARING)
1230+
self._update_status(SubmissionStatus.PREPARING, extra_information=f"ingestion_hostname-{hostname}")
12321231

12331232
# Setup cache and prune if it's out of control
12341233
self._prep_cache_dir()
@@ -1268,6 +1267,7 @@ def prepare(self):
12681267
# Before the run starts we want to download images, they may take a while to download
12691268
# and to do this during the run would subtract from the participants time.
12701269
self._get_container_image(self.container_image)
1270+
self._update_status(SubmissionStatus.RUNNING)
12711271

12721272
def start(self):
12731273
program_dir = os.path.join(self.root_dir, "program")

0 commit comments

Comments
 (0)