Skip to content

Commit 1a45d43

Browse files
committed
Change TaskGroup.create_task and tasks.create_task to **kwargs
1 parent a410125 commit 1a45d43

2 files changed

Lines changed: 4 additions & 11 deletions

File tree

Lib/asyncio/taskgroups.py

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -179,7 +179,7 @@ async def _aexit(self, et, exc):
179179
exc = None
180180

181181

182-
def create_task(self, coro, *, name=None, context=None):
182+
def create_task(self, coro, **kwargs):
183183
"""Create a new task in this group and return it.
184184
185185
Similar to `asyncio.create_task`.
@@ -193,10 +193,7 @@ def create_task(self, coro, *, name=None, context=None):
193193
if self._aborting:
194194
coro.close()
195195
raise RuntimeError(f"TaskGroup {self!r} is shutting down")
196-
if context is None:
197-
task = self._loop.create_task(coro, name=name)
198-
else:
199-
task = self._loop.create_task(coro, name=name, context=context)
196+
task = self._loop.create_task(coro, **kwargs)
200197

201198
futures.future_add_to_awaited_by(task, self._parent_task)
202199

Lib/asyncio/tasks.py

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -386,17 +386,13 @@ def __wakeup(self, future):
386386
Task = _CTask = _asyncio.Task
387387

388388

389-
def create_task(coro, *, name=None, context=None):
389+
def create_task(coro, **kwargs):
390390
"""Schedule the execution of a coroutine object in a spawn task.
391391
392392
Return a Task object.
393393
"""
394394
loop = events.get_running_loop()
395-
if context is None:
396-
# Use legacy API if context is not needed
397-
task = loop.create_task(coro, name=name)
398-
else:
399-
task = loop.create_task(coro, name=name, context=context)
395+
task = loop.create_task(coro, name=name, context=context)
400396

401397
return task
402398

0 commit comments

Comments
 (0)