Structured Concurrency in Python Asyncio: TaskGroup & Timeouts0%

Structured Concurrency in Python Asyncio: TaskGroup & Timeouts

Advanced11 min read•Updated: 2026-10-23

🐍 Structured Concurrency: TaskGroup & asyncio.timeout()

In early versions of asyncio, managing concurrent operations was often accomplished using asyncio.gather() or spawning uncoordinated background tasks with asyncio.create_task().

However, if one task failed while others were still running, uncoordinated concurrency frequently resulted in orphaned dangling tasks, resource leaks, and unhandled exceptions escaping into the void.

Python 3.11 introduced Structured Concurrency through asyncio.TaskGroup and asyncio.timeout(). Python's official documentation now recommends TaskGroup as the primary mechanism for running concurrent asynchronous tasks.

🧱 1. The Structured Concurrency Philosophy

Structured concurrency establishes a clear, parent-child contract:

"A parent task cannot complete until all its child tasks have finished. If any child task fails, all sibling tasks are automatically cancelled."

This mirrors how structured programming treats if blocks and functions—guaranteeing deterministic entry and exit points.

🚀 2. Using `asyncio.TaskGroup`

asyncio.TaskGroup is an asynchronous context manager:

1import asyncio
2 
3async def fetch_student_records(batch_id: int):
4    await asyncio.sleep(0.5)
5    print(f"Fetched records for batch {batch_id}")
6    return {"batch": batch_id, "students": 45}
7 
8async def fetch_analytics():
9    await asyncio.sleep(0.3)
10    print("Fetched analytics dashboard.")
11    return {"active_users": 120}
12 
13async def main():
14    async with asyncio.TaskGroup() as tg:
15        # Spawn concurrent tasks:
16        t1 = tg.create_task(fetch_student_records(101))
17        t2 = tg.create_task(fetch_student_records(102))
18        t3 = tg.create_task(fetch_analytics())
19 
20    # When context manager exits, ALL tasks are guaranteed complete!
21    print("All tasks finished successfully:")
22    print("Batch 101:", t1.result())
23    print("Batch 102:", t2.result())
24    print("Analytics:", t3.result())
25 
26asyncio.run(main())

🛡️ 3. Automatic Error Propagation & Sibling Cancellation

If any task inside the TaskGroup raises an exception:

1
All remaining active tasks in the group are immediately cancelled.
2
The context manager waits for all cancelled tasks to terminate cleanly.
3
The exceptions are bundled into an ExceptionGroup and re-raised!

1import asyncio
2 
3async def reliable_task():
4    try:
5        await asyncio.sleep(5)
6    except asyncio.CancelledError:
7        print("Reliable task cancelled cleanly because sibling failed!")
8        raise
9 
10async def failing_task():
11    await asyncio.sleep(0.2)
12    raise ConnectionResetError("Server dropped connection!")
13 
14async def main():
15    try:
16        async with asyncio.TaskGroup() as tg:
17            tg.create_task(reliable_task())
18            tg.create_task(failing_task())
19    except* ConnectionResetError as eg:
20        print("Caught failure inside ExceptionGroup:", eg.exceptions[0])
21 
22asyncio.run(main())

⏳ 4. Modern Async Timeouts with `asyncio.timeout()`

Prior to Python 3.11, developers used asyncio.wait_for(). Python 3.11 provides the cleaner asyncio.timeout() context manager:

1import asyncio
2 
3async def slow_api_query():
4    await asyncio.sleep(3)
5    return "Data"
6 
7async def main():
8    try:
9        async with asyncio.timeout(1.5): # Timeout after 1.5 seconds
10            result = await slow_api_query()
11            print("Received:", result)
12    except TimeoutError:
13        print("Operation timed out after 1.5 seconds!")
14 
15asyncio.run(main())

Interactive Quiz• Knowledge Check

Practice Quiz

Question 1

In which Python version was asyncio.TaskGroup introduced?

Question 2

What happens to sibling tasks in a TaskGroup when one child task raises an exception?

Question 3

How are exceptions raised by tasks inside a TaskGroup propagated to the caller?

Question 4

Which context manager was introduced in Python 3.11 to replace asyncio.wait_for()?

Question 5

Can tasks spawned via tg.create_task() escape outside the async with asyncio.TaskGroup() block?

🚀 What's Next?

In the next lesson, we will put our asynchronous skills into practice with Project: Async Web Scraper (8: Asynchronous Programming (Asyncio)).

👉 Continue to Next Lesson: Project: Async Web Scraper →

Next Lesson

Project: Async Web Scraper

Continue learning with hands-on practice, examples, and exercises in the upcoming topic.

Related Lessons

Previous Lesson	Next Lesson
Creating and Managing Tasks	Project: Async Web Scraper

Practice Quiz

Test your understanding of this lesson with 5 questions. Each question has one correct answer.

Previous Next

PreviousPrevNext

MSK Institute • Shikohabad

Loading Page Content...

Preparing courses, live labs, and learning resources.सामग्री लोड हो रही है, कृपया प्रतीक्षा करें...

Connecting serverPlease wait...

💻 Practical Labs🚀 Free Demo📜 Verified Certificates

Project: Async Web Scraper

Structured Concurrency in Python Asyncio: TaskGroup & Timeouts

Advanced11 min read•Updated: 2026-10-23

Study Materials Cheatsheet

🐍 Structured Concurrency: TaskGroup & asyncio.timeout()

In early versions of asyncio, managing concurrent operations was often accomplished using asyncio.gather() or spawning uncoordinated background tasks with asyncio.create_task().

🧱 1. The Structured Concurrency Philosophy

Structured concurrency establishes a clear, parent-child contract:

"A parent task cannot complete until all its child tasks have finished. If any child task fails, all sibling tasks are automatically cancelled."

This mirrors how structured programming treats if blocks and functions—guaranteeing deterministic entry and exit points.

🚀 2. Using `asyncio.TaskGroup`

asyncio.TaskGroup is an asynchronous context manager:

1import asyncio
2 
3async def fetch_student_records(batch_id: int):
4    await asyncio.sleep(0.5)
5    print(f"Fetched records for batch {batch_id}")
6    return {"batch": batch_id, "students": 45}
7 
8async def fetch_analytics():
9    await asyncio.sleep(0.3)
10    print("Fetched analytics dashboard.")
11    return {"active_users": 120}
12 
13async def main():
14    async with asyncio.TaskGroup() as tg:
15        # Spawn concurrent tasks:
16        t1 = tg.create_task(fetch_student_records(101))
17        t2 = tg.create_task(fetch_student_records(102))
18        t3 = tg.create_task(fetch_analytics())
19 
20    # When context manager exits, ALL tasks are guaranteed complete!
21    print("All tasks finished successfully:")
22    print("Batch 101:", t1.result())
23    print("Batch 102:", t2.result())
24    print("Analytics:", t3.result())
25 
26asyncio.run(main())

🛡️ 3. Automatic Error Propagation & Sibling Cancellation

If any task inside the TaskGroup raises an exception:

1
All remaining active tasks in the group are immediately cancelled.
2
The context manager waits for all cancelled tasks to terminate cleanly.
3
The exceptions are bundled into an ExceptionGroup and re-raised!

1import asyncio
2 
3async def reliable_task():
4    try:
5        await asyncio.sleep(5)
6    except asyncio.CancelledError:
7        print("Reliable task cancelled cleanly because sibling failed!")
8        raise
9 
10async def failing_task():
11    await asyncio.sleep(0.2)
12    raise ConnectionResetError("Server dropped connection!")
13 
14async def main():
15    try:
16        async with asyncio.TaskGroup() as tg:
17            tg.create_task(reliable_task())
18            tg.create_task(failing_task())
19    except* ConnectionResetError as eg:
20        print("Caught failure inside ExceptionGroup:", eg.exceptions[0])
21 
22asyncio.run(main())

⏳ 4. Modern Async Timeouts with `asyncio.timeout()`

Prior to Python 3.11, developers used asyncio.wait_for(). Python 3.11 provides the cleaner asyncio.timeout() context manager:

1import asyncio
2 
3async def slow_api_query():
4    await asyncio.sleep(3)
5    return "Data"
6 
7async def main():
8    try:
9        async with asyncio.timeout(1.5): # Timeout after 1.5 seconds
10            result = await slow_api_query()
11            print("Received:", result)
12    except TimeoutError:
13        print("Operation timed out after 1.5 seconds!")
14 
15asyncio.run(main())

Interactive Quiz• Knowledge Check

Practice Quiz

Question 1

In which Python version was asyncio.TaskGroup introduced?

Question 2

What happens to sibling tasks in a TaskGroup when one child task raises an exception?

Question 3

How are exceptions raised by tasks inside a TaskGroup propagated to the caller?

Question 4

Which context manager was introduced in Python 3.11 to replace asyncio.wait_for()?

Question 5

Can tasks spawned via tg.create_task() escape outside the async with asyncio.TaskGroup() block?

🚀 What's Next?

In the next lesson, we will put our asynchronous skills into practice with Project: Async Web Scraper (8: Asynchronous Programming (Asyncio)).

👉 Continue to Next Lesson: Project: Async Web Scraper →

Next Lesson

Project: Async Web Scraper

Continue learning with hands-on practice, examples, and exercises in the upcoming topic.

Related Lessons

Previous Lesson	Next Lesson
Creating and Managing Tasks	Project: Async Web Scraper

Practice Quiz

Test your understanding of this lesson with 5 questions. Each question has one correct answer.

Previous Next

🐍 Structured Concurrency: TaskGroup & asyncio.timeout()

🧱 1. The Structured Concurrency Philosophy

🚀 2. Using asyncio.TaskGroup

🛡️ 3. Automatic Error Propagation & Sibling Cancellation

⏳ 4. Modern Async Timeouts with asyncio.timeout()

Practice Quiz

🚀 What's Next?

Project: Async Web Scraper

Related Lessons

Practice Quiz

Loading Page Content...

🐍 Structured Concurrency: TaskGroup & asyncio.timeout()

🧱 1. The Structured Concurrency Philosophy

🚀 2. Using asyncio.TaskGroup

🛡️ 3. Automatic Error Propagation & Sibling Cancellation

⏳ 4. Modern Async Timeouts with asyncio.timeout()

Practice Quiz

🚀 What's Next?

Project: Async Web Scraper

Related Lessons

Practice Quiz

🚀 2. Using `asyncio.TaskGroup`

⏳ 4. Modern Async Timeouts with `asyncio.timeout()`

🚀 2. Using `asyncio.TaskGroup`

⏳ 4. Modern Async Timeouts with `asyncio.timeout()`