Denver H
12/20/2023, 2:58 PM@task()
def placeholder(val):
print(F"placeholder: {val}")
@flow(task_runner=DaskTaskRunner())
def flowtestA():
placeholder("aaa")
for i in range(10):
placeholder.submit(i)
@flow(task_runner=SequentialTaskRunner())
def flowtestB():
placeholder("aaa")
for i in range(10):
placeholder.submit(i)
if __name__ == "__main__":
flowtestA()
flowtestB()
is there a way for flowtestA and flowtestB to run in parallel and then the tasks in flowtestA run with threading due to the DaskTaskRunner decorator but run sequentially in flowtestB?