cuddly-bird-81297
02/22/2023, 4:18 PM.with_overrides(name="blah")
but it didn't seem to be picked up.freezing-airport-6809
freezing-airport-6809
freezing-airport-6809
cuddly-bird-81297
02/22/2023, 4:22 PMcuddly-bird-81297
02/22/2023, 4:24 PMtraining_file = data_aggregation(input_parquet_dir=output_file).with_overrides(name="agg_stuff")
cuddly-bird-81297
02/22/2023, 4:25 PMfreezing-airport-6809
thankful-minister-83577
thankful-minister-83577
@dynamic
tasks, itâs a little different. you can use the same syntax still. but to clarify what happens is that the actual details of the task that is run is not the version thatâs stored in the database. (this is kinda a transparent detail for you, but just to clarify)thankful-minister-83577
cuddly-bird-81297
02/24/2023, 3:26 PMfrom 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.freezing-airport-6809
late-eye-50215
02/24/2023, 5:26 PMsquare-boots-41503
03/06/2023, 7:38 PM@dynamic
task using .with_overrides()
? I tried name=
(didnât work) and node_name=
(failed to run).square-boots-41503
03/06/2023, 7:51 PMwith_overrides
. And by âfailed to runâ, I mean that the task would exit with a failure message.