Skip to content

Commit 3c44896

Browse files
committed
[zephyr] Include stage name in worker task-execution log
The worker previously logged "Executing task for shard N"; add the stage name so per-shard logs identify which stage the shard belongs to when multiple stages run in the same pipeline.
1 parent 31e8ee3 commit 3c44896

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

lib/zephyr/src/zephyr/execution.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1163,7 +1163,13 @@ def _poll_loop(self, coordinator: ActorHandle) -> None:
11631163
# Unpack task and config
11641164
task, attempt, config = response
11651165

1166-
logger.info("[%s] Executing task for shard %d (attempt %d)", self._worker_id, task.shard_idx, attempt)
1166+
logger.info(
1167+
"[%s] Executing task for stage %s shard %d (attempt %d)",
1168+
self._worker_id,
1169+
task.stage_name,
1170+
task.shard_idx,
1171+
attempt,
1172+
)
11671173
try:
11681174
t_0 = time.monotonic()
11691175
result, task_counters = self._execute_shard(task, config)

0 commit comments

Comments
 (0)