Muddassir Shaikh
01/19/2022, 9:23 AM[2022-01-19 14:45:49+0530] INFO - prefect.TaskRunner | Task 'Tuple': Finished task run for task with final state: 'Success'
[2022-01-19 14:45:49+0530] INFO - prefect.TaskRunner | Task 'Tuple': Finished task run for task with final state: 'Success'
[2022-01-19 14:45:49+0530] INFO - prefect.TaskRunner | Task 'Tuple': Finished task run for task with final state: 'Success'
[2022-01-19 14:45:49+0530] INFO - prefect.TaskRunner | Task 'Tuple': Finished task run for task with final state: 'Success'
[2022-01-19 14:45:49+0530] INFO - prefect.TaskRunner | Task 'Tuple': Finished task run for task with final state: 'Success'
[2022-01-19 14:45:49+0530] INFO - prefect.TaskRunner | Task 'Tuple': Finished task run for task with final state: 'Success'
[2022-01-19 14:45:49+0530] INFO - prefect.TaskRunner | Task 'Tuple': Finished task run for task with final state: 'Success'
[2022-01-19 14:45:49+0530] INFO - prefect.TaskRunner | Task 'Tuple': Finished task run for task with final state: 'Success'
[2022-01-19 14:45:49+0530] INFO - prefect.TaskRunner | Task 'List': Starting task run...
[2022-01-19 14:45:49+0530] INFO - prefect.TaskRunner | Task 'List': Starting task run...
[2022-01-19 14:45:50+0530] INFO - prefect.TaskRunner | Task 'List': Starting task run...
[2022-01-19 14:45:50+0530] INFO - prefect.TaskRunner | Task 'List': Starting task run...
Anna Geller
import random
from prefect import Flow, task
@task
def a_number():
return random.randint(0, 100)
@task
def get_sum(x):
return sum(x)
with Flow("Using Collections") as flow:
a = a_number()
b = a_number()
s = get_sum([a, b])
if __name__ == "__main__":
flow.visualize()
Compare it to this:
import random
from prefect import Flow, task
@task
def a_number():
return random.randint(0, 100)
@task
def merge_into_list(x, y):
return [x, y]
@task
def get_sum(x):
return sum(x)
with Flow("Using Collections") as flow:
a = a_number()
b = a_number()
a_list = merge_into_list(a, b)
s = get_sum(a_list)
if __name__ == "__main__":
flow.visualize()
Muddassir Shaikh
01/19/2022, 12:33 PM