diff --git a/test.py b/test.py index 4d719ed..88a3fba 100644 --- a/test.py +++ b/test.py @@ -1,4 +1,19 @@ -from prefect import flow +from prefect import flow, task +from prefect.assets import materialize + +@materialize("s3://assets_a") +def assets_a(): + print("assets_a") + + +@materialize("s3://assets_b", asset_deps=["s3://assets_a"]) +def assets_b(): + print("assets_b") + +@task(name="task_a") +def task_a(): + assets_b() + print("task_a") @flow(log_prints=True) def explain_flows():