I'm trying to run train a variety of models against a single dataset. The general process works fine but I can't find a clean way to dynamically rename the tasks for each of the model types. Am I missing something? I tried

.with_overrides(name="blah")

but it didn't seem to be picked up.

This should work

yes. Let me triple check I didn't miss something if that was supposed to work.

Cc @Yee quick way to triage this

hey @Dan Corbiani - just want to clarify a couple things. the task name in normal workflows will not change… the name of the task is a parameter in the TaskTemplate and it’s stored in the database. however as ketan suggested you can override the node name. you can check out this unmerged example which we cooked up for internal testing.

Finally got back to this. I think it's an error in the UI rendering. Here is the code I'm using:

from typing import List

from flytekit import dynamic, task, workflow


@task()
def model_training(name: str) -> str:
    print(f"Hello {name}")
    return name


@task()
def hello_person(name: str) -> str:
    print(f"Hello {name}")
    return name


@dynamic
def people(names: List[str]) -> List[str]:
    ack = []
    for name in names:
        ack.append(model_training(name=name))
    return ack


@workflow()
def hello_people(names: List[str]) -> List[str]:
    ack = people(names=names)
    other_names = ["bob", "sue"]
    for other_name in other_names:
        hello_person(name=other_name).with_overrides(node_name=f"hello_{other_name}")
    print(ack)
    return ack


if __name__ == "__main__":
    output = hello_people(names=["bob", "sue"])
    type(output)

It seems to render correctly on the node page but not on the graph. It's also correct on the timeline view.

Cc @Jason Porter / @Soham

Ah okay, yeah its definitely not supposed to do that; we'll pick that up this sprint 👍 https://github.com/flyteorg/flyte/issues/3370

does anyone know if it’s possible to set the name of a

@dynamic

task using

.with_overrides()

? I tried

name=

(didn’t work) and

node_name=

(failed to run).