@Marvin I have this example flow to run concurrently with Dask...

@flow(
    task_runner=DaskTaskRunner(
        cluster_kwargs={"n_workers": 6,"threads_per_worker": 1},
    ),
)
def parallel_flow(n: int = 6) -> int:
    # Fan-out: these run concurrently on Dask workers
    futures = [fetch.submit(i) for i in range(n)]

    # Keep the UI graph parallel by passing futures, not resolved results
    total = combine.submit(futures)
    return total.result()

Help me rewrite this if it was with

.map()

🔧 Using:

display_callable_signature

📊 Tools used: •

display_callable_signature

(10x) •

explore_module_offerings

(10x) •

research_prefect_topic

(10x) •

review_common_3x_gotchas

(10x) •

search_prefect_3x_docs

(10x)