Skip to content

Commit 2a59af1

Browse files
committed
Update prepare
1 parent 2a06cc9 commit 2a59af1

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

compute_worker/compute_worker.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1233,6 +1233,9 @@ def prepare(self):
12331233
# Only during prediction step do we want to announce "preparing"
12341234
self._update_status(SubmissionStatus.PREPARING, extra_information=f"ingestion_hostname-{hostname}")
12351235

1236+
# Ensure output_dir exists on the host
1237+
self._get_host_path(self.output_dir)
1238+
12361239
# Setup cache and prune if it's out of control
12371240
self._prep_cache_dir()
12381241

0 commit comments

Comments
 (0)