Geert
12/04/2023, 9:09 AM@task
def some_task():
...
s3_path = (
pathlib.Path(...)
/ flytekit.current_context().execution_id.name # <---- unique (at least in our flow it returns an ID)
/ flytekit.current_context().task_id.name # <---- non-unique, it returns a name. Would like to have a unique id within a workflow which I think is node_id?
)
Geert
12/04/2023, 9:10 AMGeert
12/04/2023, 9:15 AMSamhita Alla
Geert
12/05/2023, 10:41 AMGeert
12/05/2023, 10:41 AM