25 lines
500 B
Python
25 lines
500 B
Python
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!")
|
|
task_a()
|
|
|
|
if __name__ == "__main__":
|
|
explain_flows() |