Michael Reynolds
07/26/2022, 3:11 PMorion
for non-terminating long running workflows?Anna Geller
07/26/2022, 3:20 PMMichael Reynolds
07/26/2022, 3:25 PM@task
def my_listen_task():
pass
@task
def my_process_task(data):
pass
@task
def my_persistence_task(data):
pass
@flow
def my_flow():
while True:
updates = my_listen_task()
results = my_process_task(updates)
if len(results) > 0:
my_persistence_task(results)
if __name__ == '__main__':
run_pipeline()
Anna Geller
07/26/2022, 9:32 PMMichael Reynolds
07/27/2022, 7:49 PM