Skip to content

Commit d4fa04a

Browse files
committed
added node index to current_context
Signed-off-by: Atharva <[email protected]>
1 parent ff4c79c commit d4fa04a

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

flytekit/bin/entrypoint.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -470,7 +470,9 @@ def setup_execution(
470470
if checkpoint_path is not None:
471471
checkpointer = SyncCheckpoint(checkpoint_dest=checkpoint_path, checkpoint_src=prev_checkpoint)
472472
logger.debug(f"Checkpointer created with source {prev_checkpoint} and dest {checkpoint_path}")
473-
473+
474+
node_index = _compute_array_job_index()
475+
474476
execution_parameters = ExecutionParameters(
475477
execution_id=_identifier.WorkflowExecutionIdentifier(
476478
project=exe_project,
@@ -498,6 +500,7 @@ def setup_execution(
498500
output_metadata_prefix=output_metadata_prefix,
499501
checkpoint=checkpointer,
500502
task_id=_identifier.Identifier(_identifier.ResourceType.TASK, tk_project, tk_domain, tk_name, tk_version),
503+
node_index=node_index,
501504
)
502505

503506
metadata = {

0 commit comments

Comments
 (0)