Lee Ning Jie Leon
09/22/2023, 8:09 AMwith_overrides(node_name=...)
in dynamic workflownode_id
@task
def echo_task(input: int):
print(input)
@dynamic
def t1():
for i in range(3):
echo_task(input=i).with_overrides(node_name=f"""echo_task_node_name_override_{i}""")
@workflow
def wf_1():
t1()
override on task in a workflow works as expected
@task
def echo_task(input: int):
print(input)
@workflow
def wf_1():
echo_task(input=1).with_overrides(node_name=f"""echo_task_node_name_override_1""")
Geert
09/22/2023, 8:49 AMLee Ning Jie Leon
09/22/2023, 8:52 AM