Maroun Khriesh
@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)
Bring 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.