This message was deleted.
# ask-marvin
s
This message was deleted.
m
Your message was too long by 8 tokens - please shorten it and try again. For reference, here's your message at the allowed limit:
Why do my tasks run sequentially when they are in concurrent subflows using asyncio. Here is my code:
```from prefect import flow, get_run_logger, task import asyncio @flow async def simple_flow(): await asyncio.sleep(10) @task def simple_task(): asyncio.run(asyncio.sleep(10)) @flow async def flow_with_tasks(): simple_task1 = simple_task.submit() simple_task2 = simple_task.submit() simple_task1.result() simple_task2.result() @flow async def flow_with_one_task(): simple_task() @flow def sync_flow(): simple_task() @flow async def test_pipeline(): logger = get_run_logger() logger.info("Local timezone: Australia/Melbourne") sync_flow() flow1 = await flow_with_one_task() flow1 = asyncio.create_task(flow_with_one_task(return_state=True)) flow2 = asyncio.create_task(simple_flow(return_state=True)) flow3 = asyncio.create_task(flow_with_one_task(return_state=True)) flow4 = asyncio.create_task(flow_with_tasks(return_state=True)) flow5 = asyncio.create_task(flow_with_one_task(return_state=True)) flow6 = asyncio.create_task(flow_with_one_task(return_state=True)) await asyncio.gather(flow3, flow4, flow2, flow5, flow6, flow1) if name == '__main