Fix patchcheck for asyncio.tasks (#108159)

This commit is contained in:
Kumar Aditya 2023-08-20 14:30:42 +05:30 committed by GitHub
parent 1dc0c58d2b
commit b1e5d2c601
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -935,21 +935,21 @@ def callback():
def create_eager_task_factory(custom_task_constructor): def create_eager_task_factory(custom_task_constructor):
"""Create a function suitable for use as a task factory on an event-loop. """Create a function suitable for use as a task factory on an event-loop.
Example usage: Example usage:
loop.set_task_factory( loop.set_task_factory(
asyncio.create_eager_task_factory(my_task_constructor)) asyncio.create_eager_task_factory(my_task_constructor))
Now, tasks created will be started immediately (rather than being first Now, tasks created will be started immediately (rather than being first
scheduled to an event loop). The constructor argument can be any callable scheduled to an event loop). The constructor argument can be any callable
that returns a Task-compatible object and has a signature compatible that returns a Task-compatible object and has a signature compatible
with `Task.__init__`; it must have the `eager_start` keyword argument. with `Task.__init__`; it must have the `eager_start` keyword argument.
Most applications will use `Task` for `custom_task_constructor` and in Most applications will use `Task` for `custom_task_constructor` and in
this case there's no need to call `create_eager_task_factory()` this case there's no need to call `create_eager_task_factory()`
directly. Instead the global `eager_task_factory` instance can be directly. Instead the global `eager_task_factory` instance can be
used. E.g. `loop.set_task_factory(asyncio.eager_task_factory)`. used. E.g. `loop.set_task_factory(asyncio.eager_task_factory)`.
""" """
def factory(loop, coro, *, name=None, context=None): def factory(loop, coro, *, name=None, context=None):
return custom_task_constructor( return custom_task_constructor(