the system i'm trying to create does the following: • i have a

parent_flow

• the

parent_flow

kicks of

subflow_1

,

subflow_2

asynchronously •

subflow_1

has no dependencies, but

subflow_2

depends on the result of

subflow_1

, so it triggers

subflow_1

as well • ** i don't want to have to topologically sort all my subflows to figure out the optimal execution order, i'd rather rely on prefect caching to minimize work

here's code to reproduce the issue (there's stuff that is duplicated e.g. the logic between subflows, but in reality each subflow might do some different stuff)

here's the full error message

fwiw: the subflow stuff works fine, but the second i introduce `task`s into the subflows, it falls apart

bumping this error from yesterday!

@task
def test_task():
    print("hi")

@flow
def test_flow():
    with tags("testing"):
        test_task()

if __name__ == '__main__':
    test_flow()

isn't showing tags in the orion ui when using postgres, but does show them when using sqlite

doesnt look like the tags exist in the db either

ah, this doesnt look like a postgres vs sqlite issue, i think its an async issue. i'll create a reproducible example and create the issue!

closing the loop here: this isn't an issue. i realized i'm doing the

with tags(...):

block in the wrong place, and it should be around the

asyncio.gather

call instead:

# not this
subflows = []
with tags("some_tag"):
    subflows.append(my_subflow())

asyncio.gather(*subflows)

# do this instead

subflows = []
subflows.append(my_subflow())

with tags("some_tag"):
    asyncio.gather(*subflows)

thank you for addressing my original issue though! and i'll keep an eye out for any release notes regarding using sqlite for async flows/tasks locally 🙂