Phil Crooks

ParallelFor does not start as many pods as expected

3

Running this code: ``` parallel_task = dsl.ParallelFor(repo_tasks.output, parallelism=50) with parallel_task as item: # this is a func_to_container_op with boto3 unpack_task = get_file(item) # this is a func_to_container_op commits_input_task = add_log_data_to_input(unpack_task.output,...