vk
09/19/2022, 8:08 PMfrom prefect import flow, task
from prefect import get_run_logger
import time
@task
def run_computation():
logger = get_run_logger()
<http://logger.info|logger.info>("run some computation")
time.sleep(30)
return 123
@task
def dependent_task(x):
logger = get_run_logger()
<http://logger.info|logger.info>("run dependent task")
time.sleep(10)
@task
def independent_task(i):
logger = get_run_logger()
<http://logger.info|logger.info>(f"run independent task: {i}")
time.sleep(3)
@flow(name="orion2")
def f():
x = run_computation()
independent_task(0)
for i in range(1, 10):
independent_task(i)
dependent_task(x)
if __name__ == '__main__':
f()
Jenny
09/19/2022, 8:34 PMvk
09/20/2022, 7:01 PMJenny
09/20/2022, 7:14 PMvk
09/20/2022, 7:15 PMJenny
09/20/2022, 7:39 PM