Rasmus Lindqvist
01/09/2023, 3:22 PM@task(
name="FirstTask",
log_stdout=True,
target=f"{flow_name}/2023/" + "{date:%m-%d}" + f"/{task_name}/output.csv"
)
def first_task() -> pd.DataFrame:
data = get_some_data()
return data
with Flow(
"TestFlow",
result=GCSResult(bucket="my-bucket", location="{flow_name}/"+ "{date:%m-%d}" + "/{task_name}"),
):
data = first_task()
second_task(data)
Tim-Oliver
01/09/2023, 3:27 PMRasmus Lindqvist
01/09/2023, 4:17 PMTim-Oliver
01/09/2023, 4:20 PMRasmus Lindqvist
01/09/2023, 4:25 PM