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 PMBring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.
Powered by