Quick question. I know that .map() can be used as a single for-loop in a flow. Is there a way to use .map() to create a nested for-loop though?

Hey @Samuel Tober, the quick answer is no. The first map already parallelizes across available resources so the nested map would not add anything.

Ok! What is the recommended way for doing this?

Maybe put the loop inside the task like this?

from prefect import task, Flow

@task
def abc(x):
    return [x, x+1]

@task
def bcd(y):
    return y + 1

@task
def cde(z):
    # z is two elements so we would want a map
    # but we cant here
    out = []
    for _ in z:
        bcd.run(_)
        out.append(_)
    
    return out

with Flow("a") as flow:
    items = [1,2,3,4]
    a = abc.map(items)
    b = cde.map(a)
    
flow.run()