Kaibo Chen
05/07/2023, 9:02 PMimport job_wrapper
job_list = ["job_a","job_b",...]
for job in job_list:
@flow(name=job)
def run_job():
job_wrapper(job)
However, because that current deployment requires a unique entry_point function as well flow_name, now what i have is
import job_wrapper
@flow(name="job_a")
def run_job_a():
job_wrapper("job_a")
@flow(name="job_b")
def run_job_b():
job_wrapper("job_b")
...
Is there a less repetitive way of doing this that I might have missedDeceivious
05/08/2023, 9:05 AMKaibo Chen
05/08/2023, 10:18 AMKaibo Chen
05/08/2023, 10:19 AMDeceivious
05/08/2023, 10:50 AMDeceivious
05/08/2023, 10:50 AM