Skip to content

Commit e2a84ee

Browse files
committed
refactor: Removed obsolete event_loop_fixture_id from fixture synchronizers.
1 parent 8cc0fa5 commit e2a84ee

File tree

1 file changed

+6
-12
lines changed

1 file changed

+6
-12
lines changed

pytest_asyncio/plugin.py

Lines changed: 6 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -284,28 +284,23 @@ def _preprocess_async_fixtures(
284284
and "event_loop" not in fixturedef.argnames
285285
):
286286
fixturedef.argnames += ("event_loop",)
287-
_synchronize_async_fixture(
288-
fixturedef,
289-
event_loop_fixture_id,
290-
)
287+
_synchronize_async_fixture(fixturedef)
291288
assert _is_asyncio_fixture_function(fixturedef.func)
292289
processed_fixturedefs.add((fixturedef, event_loop_fixture_id))
293290

294291

295-
def _synchronize_async_fixture(
296-
fixturedef: FixtureDef, event_loop_fixture_id: str
297-
) -> None:
292+
def _synchronize_async_fixture(fixturedef: FixtureDef) -> None:
298293
"""
299294
Wraps the fixture function of an async fixture in a synchronous function.
300295
"""
301296
if inspect.isasyncgenfunction(fixturedef.func) or getattr(
302297
fixturedef.func, "_async_fixture", False
303298
):
304-
_wrap_asyncgen_fixture(fixturedef, event_loop_fixture_id)
299+
_wrap_asyncgen_fixture(fixturedef)
305300
elif inspect.iscoroutinefunction(fixturedef.func) or getattr(
306301
fixturedef.func, "_async_fixture", False
307302
):
308-
_wrap_async_fixture(fixturedef, event_loop_fixture_id)
303+
_wrap_async_fixture(fixturedef)
309304

310305

311306
def _add_kwargs(
@@ -342,9 +337,8 @@ def _perhaps_rebind_fixture_func(
342337
return func
343338

344339

345-
def _wrap_asyncgen_fixture(fixturedef: FixtureDef, event_loop_fixture_id: str) -> None:
340+
def _wrap_asyncgen_fixture(fixturedef: FixtureDef) -> None:
346341
fixture = fixturedef.func
347-
348342
if getattr(fixture, "_async_fixture", False):
349343
return fixture
350344

@@ -398,7 +392,7 @@ async def async_finalizer() -> None:
398392
fixturedef.func = _asyncgen_fixture_wrapper
399393

400394

401-
def _wrap_async_fixture(fixturedef: FixtureDef, event_loop_fixture_id: str) -> None:
395+
def _wrap_async_fixture(fixturedef: FixtureDef) -> None:
402396
fixture = fixturedef.func
403397

404398
if getattr(fixture, "_async_fixture", False):

0 commit comments

Comments
 (0)