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(): print("run any python code here!") print("encapsulate that business logic!") if __name__ == "__main__": explain_flows()