We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e792cd7 commit 5602a78Copy full SHA for 5602a78
1 file changed
axlearn/cloud/gcp/runners/gke.py
@@ -640,6 +640,9 @@ def _execute(self):
640
metrics.record_job_wait_for_build(
641
cfg.name, time.perf_counter() - wait_build_start
642
)
643
+ self._maybe_publish(
644
+ cfg.name, msg="Cloud build finished", state=JobLifecycleState.STARTING
645
+ )
646
except RuntimeError as e:
647
logging.error("Bundling failed: %s. Aborting the job.", e)
648
return
@@ -649,6 +652,9 @@ def _execute(self):
649
652
self._pre_provisioner.create_for(self._inner)
650
653
651
654
self._inner.execute()
655
656
+ cfg.name, msg="Provisioning resources", state=JobLifecycleState.STARTING
657
658
elif status == GKERunnerJob.Status.SUSPENDED:
659
# Job is in SUSPENDED state.
660
if suspended_since is None:
0 commit comments