asyncio.as_completed() raises "no running event loop" when created outside a running loop (3.14 regression)
Personne n'a encore pris cette issue.
- Langage dominant
- Python
- Étoiles
- 77.2k
- Forks
- 36k
- Métriques de merge des PR
- Métriques de PR en attente
Description
Bug report
Bug description:
Since 3.14, asyncio.as_completed() raises RuntimeError: no running event loop when the iterator is created outside of a running event loop, even though the futures are then driven with loop.run_until_complete(). This pattern works on 3.13 and is the same pattern that asyncio.gather() still supports.
import asyncio
async def work(i):
await asyncio.sleep(0.01 * i)
return i
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
tasks = [loop.create_task(work(i)) for i in (2, 1)]
for f in asyncio.as_completed(tasks):
print(loop.run_until_complete(f))
loop.close()
3.13:
1
2
main (and 3.14):
Traceback (most recent call last):
File "repro.py", line 10, in <module>
for f in asyncio.as_completed(tasks):
~~~~~~~~~~~~~~~~~~~~^^^^^^^
File ".../Lib/asyncio/tasks.py", line 581, in __init__
self._cur_task = current_task()
RuntimeError: no running event loop
The cause is the awaited-by tracking added in gh-91048: _AsCompletedIterator.__init__ calls current_task() unconditionally. gather() got the same tracking but guards it with events._get_running_loop() and falls back to cur_task = None (which future_add_to_awaited_by() already treats as a no-op). as_completed() should do the same.
I have a fix with a regression test ready.
CPython versions tested on:
CPython main branch, 3.14
Operating systems tested on:
macOS
Linked PRs
- gh-157857
Guide de contribution
Ouvrir le guide de contribution
Par où commencer
- Lisez l'issue en entier, puis le guide de contribution du projet.
- Signalez en commentaire que vous la prenez — cela évite que deux personnes fassent le même travail.
- Forkez le dépôt et travaillez sur une branche.
- Ouvrez une pull request qui référence le numéro de l'issue.
Piste de recherche
Commencez dans Lib/asyncio/tasks.py, au niveau de _AsCompletedIterator.init, puis comparez avec le traitement correspondant dans asyncio.gather(). Examinez le test de régression mentionné dans l’issue et exécutez la suite de tests asyncio concernée. C’est terminé lorsque le modèle loop.run_until_complete() signalé fonctionne sur 3.14 sans casser les tests asyncio existants.
Rédigé par le modèle d'indexation à partir du texte de l'issue.
Évaluation
- Stack technique
- python
- Domaine
- backend
- Type d'issue
- Bug
- Difficulté
- 2/5
- Temps estimé
- 1-3 heures
- Activité
- À l'abandon
- Clarté
- Clairement spécifiée
- Accessibilité débutants
- 25/100