@Marvin Can I run prefect flows in parallel like prefect tasks with the .submit or .map function?

It seems there was an issue retrieving detailed documentation on running flows in parallel. However, from the basic code example provided, we can infer that flows can indeed be called like normal Python functions and thus can potentially be run concurrently using standard Python concurrency utilities. Here is an example of how you might run Prefect flows in parallel using the

concurrent.futures

module:

python
from prefect import flow
import concurrent.futures

@flow
def flow_a():
    print("Running Flow A")
    # Flow A tasks go here

@flow
def flow_b():
    print("Running Flow B")
    # Flow B tasks go here

if __name__ == "__main__":
    with concurrent.futures.ThreadPoolExecutor() as executor:
        futures = [executor.submit(flow_a), executor.submit(flow_b)]
        concurrent.futures.wait(futures)

This example uses

ThreadPoolExecutor

to run

flow_a

and

flow_b

in parallel. You can replace it with

ProcessPoolExecutor

if you want separate processes instead of threads. For more advanced features or specific methods in Prefect for running flows in parallel, I recommend checking the official Prefect documentation or their community forums. Link: https://raw.githubusercontent.com/zzstoatzz/prefect-code-examples/main/examples/flows/basic.py