Maroun Khriesh
09/29/2024, 9:04 AM@flow(log_prints=True, task_runner=ConcurrentTaskRunner)
def sample_flow(sample_index) -> None:
...
def samples_parallel_executer(sample_indices):
for sample_index in sample_indices: #TODO: Add parallelism
sample_flow(sample_index)
However, it wasn't obvious for me how to parallelize flows execution in Prefect. Any idea what is the best practices?
Thanks in advance for your help!