Kaibo Chen05/07/2023, 9:02 PM
However, because that current deployment requires a unique entry_point function as well flow_name, now what i have is
import job_wrapper job_list = ["job_a","job_b",...] for job in job_list: @flow(name=job) def run_job(): job_wrapper(job)
Is there a less repetitive way of doing this that I might have missed
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") ...
Deceivious05/08/2023, 9:05 AM
Kaibo Chen05/08/2023, 10:18 AM
Deceivious05/08/2023, 10:50 AM