Emil Ordoñez08/11/2022, 5:27 AM
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.
from 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()
Josh Furlin08/11/2022, 3:39 PM
Khuyen Tran08/11/2022, 8:14 PM