asyncio.current_task() is None for asyncio.tasks._PyTask 3.14a6

[graingert]

Bug report

Bug description:

import asyncio

async def main():
    async def asyncfn():
        assert asyncio.current_task()

    t = asyncio.tasks._CTask(asyncfn())
    await t
    print("ctask worked")
    t = asyncio.tasks._PyTask(asyncfn())
    await t
    print("pytask worked")

asyncio.run(main())

CPython versions tested on:

CPython main branch

Operating systems tested on:

No response

[graingert]

bisecting now

[graingert]

introduced in 660f126

[kumaraditya303]

Mixing pure python and C implementation is unsupported.

[graingert]

all of the combinations are tested and supported

cpython/Lib/test/test_asyncio/test_tasks.py

Lines 2874 to 2947 in fb17f41

	@unittest.skipUnless(hasattr(futures, '_CFuture') and
	hasattr(tasks, '_CTask'),
	'requires the C _asyncio module')
	@add_subclass_tests
	class CTask_CFuture_SubclassTests(BaseTaskTests, test_utils.TestCase):
	Task = getattr(tasks, '_CTask', None)
	Future = getattr(futures, '_CFuture', None)
	all_tasks = getattr(tasks, '_c_all_tasks', None)
	current_task = staticmethod(getattr(tasks, '_c_current_task', None))
	@unittest.skipUnless(hasattr(tasks, '_CTask'),
	'requires the C _asyncio module')
	@add_subclass_tests
	class CTaskSubclass_PyFuture_Tests(BaseTaskTests, test_utils.TestCase):
	Task = getattr(tasks, '_CTask', None)
	Future = futures._PyFuture
	all_tasks = getattr(tasks, '_c_all_tasks', None)
	current_task = staticmethod(getattr(tasks, '_c_current_task', None))
	@unittest.skipUnless(hasattr(futures, '_CFuture'),
	'requires the C _asyncio module')
	@add_subclass_tests
	class PyTask_CFutureSubclass_Tests(BaseTaskTests, test_utils.TestCase):
	Future = getattr(futures, '_CFuture', None)
	Task = tasks._PyTask
	all_tasks = staticmethod(tasks._py_all_tasks)
	current_task = staticmethod(tasks._py_current_task)
	@unittest.skipUnless(hasattr(tasks, '_CTask'),
	'requires the C _asyncio module')
	class CTask_PyFuture_Tests(BaseTaskTests, test_utils.TestCase):
	Task = getattr(tasks, '_CTask', None)
	Future = futures._PyFuture
	all_tasks = getattr(tasks, '_c_all_tasks', None)
	current_task = staticmethod(getattr(tasks, '_c_current_task', None))
	@unittest.skipUnless(hasattr(futures, '_CFuture'),
	'requires the C _asyncio module')
	class PyTask_CFuture_Tests(BaseTaskTests, test_utils.TestCase):
	Task = tasks._PyTask
	Future = getattr(futures, '_CFuture', None)
	all_tasks = staticmethod(tasks._py_all_tasks)
	current_task = staticmethod(tasks._py_current_task)
	class PyTask_PyFuture_Tests(BaseTaskTests, SetMethodsTest,
	test_utils.TestCase):
	Task = tasks._PyTask
	Future = futures._PyFuture
	all_tasks = staticmethod(tasks._py_all_tasks)
	current_task = staticmethod(tasks._py_current_task)
	@add_subclass_tests
	class PyTask_PyFuture_SubclassTests(BaseTaskTests, test_utils.TestCase):
	Task = tasks._PyTask
	Future = futures._PyFuture
	all_tasks = staticmethod(tasks._py_all_tasks)
	current_task = staticmethod(tasks._py_current_task)
	@unittest.skipUnless(hasattr(tasks, '_CTask'),
	'requires the C _asyncio module')
	class CTask_Future_Tests(test_utils.TestCase):

[kumaraditya303]

If you are creating a pure python task then you need to call the pure python version of current_task i.e. asyncio.tasks._py_current_task

[graingert]

ah I see ok