Emil Ordoñez
08/11/2022, 5:27 AMfrom prefect import task, flow, get_run_logger
@task
def get_x(x: int=1):
return x
@task
def sum_task(x: int=1, y: int=2):
return x + y
@flow
def flow_exec(init: int=1, end: int=4):
i=1
x1 = get_x(i)
sum1 = sum_task(x1)
i = i+1
x2=get_x(i)
sum2 = sum_task(x2)
i = i+1
x3=get_x(i)
sum3 = sum_task(x3)
i = i+1
x4=get_x(i)
sum4 = sum_task(x4)
flow_exec()
I've coded in this ways (Xn variables) instead of appending variables to a list for simplifying the code.
This is just a simple equivalent recreation of a real use case that I have that consists of iterating through a list of integrator.io flows and running them from Prefect instead of using the integrated scheduler on integrator.io
I'm having this same issue on my real case. I'm putting this here to see if you can help me understand this Radar UI, maybe I'm just not getting the whole idea, or maybe I can help troubleshooting or providing ideas.
Sorry for the long text, I just wanted to be very explicit.Josh Furlin
08/11/2022, 3:39 PMKhuyen Tran
08/11/2022, 8:14 PM