Skip to content

Commit 5602a78

Browse files
Weiwei Yangchanglan
authored andcommitted
Add job events for build and provisioning
GitOrigin-RevId: d32fdd105ebb818ef26d274a6e0fc04ebc8380d9
1 parent e792cd7 commit 5602a78

File tree

1 file changed

+6
-0
lines changed
  • axlearn/cloud/gcp/runners

1 file changed

+6
-0
lines changed

axlearn/cloud/gcp/runners/gke.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -640,6 +640,9 @@ def _execute(self):
640640
metrics.record_job_wait_for_build(
641641
cfg.name, time.perf_counter() - wait_build_start
642642
)
643+
self._maybe_publish(
644+
cfg.name, msg="Cloud build finished", state=JobLifecycleState.STARTING
645+
)
643646
except RuntimeError as e:
644647
logging.error("Bundling failed: %s. Aborting the job.", e)
645648
return
@@ -649,6 +652,9 @@ def _execute(self):
649652
self._pre_provisioner.create_for(self._inner)
650653

651654
self._inner.execute()
655+
self._maybe_publish(
656+
cfg.name, msg="Provisioning resources", state=JobLifecycleState.STARTING
657+
)
652658
elif status == GKERunnerJob.Status.SUSPENDED:
653659
# Job is in SUSPENDED state.
654660
if suspended_since is None:

0 commit comments

Comments
 (0)