Gosia
04/26/2023, 3:37 PMZanie
04/26/2023, 3:40 PMfinal_task.submit(wait_for=[allow_failure(t) for t in upstream_futures])
Gosia
04/26/2023, 3:40 PMZanie
04/26/2023, 3:41 PMupstream_futures = []
upstream_futures.append(indepent_task_1.submit(...))
upstream_futures.append(indepent_task_2.submit(...))
Gosia
04/26/2023, 3:42 PMallow_failure
bit. Thanks!