Programmiererforum

Code: Select all

from flytekit import map_task, task, workflow

@task
def do_something(value: str) -> str:
print(f"launched: {value}", flush=True)
time.sleep(60)  # fakes long process time
return f"{value}-processed"

@workflow
def do_multiple_things() -> list[str]:
values = ["foo", "bar", "baz"]
return map_task(do_something)(value=values)