Skip to content

Commit 09e49ef

Browse files
committed
refactor: _add_kwargs no longer requires the event loop fixture id.
1 parent a360066 commit 09e49ef

File tree

1 file changed

+5
-9
lines changed

1 file changed

+5
-9
lines changed

pytest_asyncio/plugin.py

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -316,16 +316,15 @@ def _synchronize_async_fixture(
316316
def _add_kwargs(
317317
func: Callable[..., Any],
318318
kwargs: Dict[str, Any],
319-
event_loop_fixture_id: str,
320319
event_loop: asyncio.AbstractEventLoop,
321320
request: FixtureRequest,
322321
) -> Dict[str, Any]:
323322
sig = inspect.signature(func)
324323
ret = kwargs.copy()
325324
if "request" in sig.parameters:
326325
ret["request"] = request
327-
if event_loop_fixture_id in sig.parameters:
328-
ret[event_loop_fixture_id] = event_loop
326+
if "event_loop" in sig.parameters:
327+
ret["event_loop"] = event_loop
329328
return ret
330329

331330

@@ -369,9 +368,7 @@ def _asyncgen_fixture_wrapper(request: FixtureRequest, **kwargs: Any):
369368
)
370369
event_loop = request.getfixturevalue(event_loop_fixture_id)
371370
kwargs.pop(event_loop_fixture_id, None)
372-
gen_obj = func(
373-
**_add_kwargs(func, kwargs, event_loop_fixture_id, event_loop, request)
374-
)
371+
gen_obj = func(**_add_kwargs(func, kwargs, event_loop, request))
375372

376373
async def setup():
377374
res = await gen_obj.__anext__()
@@ -410,6 +407,7 @@ def _wrap_async_fixture(
410407
event_loop_id_mapping = getattr(fixture, "_event_loop_id_mapping", {})
411408
event_loop_id_mapping[event_loop_fixture_name] = event_loop_fixture_id
412409
event_loop_id_mapping["function"] = event_loop_fixture_id
410+
print(fixturedef, event_loop_id_mapping)
413411

414412
if getattr(fixture, "_async_fixture", False):
415413
return fixture
@@ -425,9 +423,7 @@ def _async_fixture_wrapper(request: FixtureRequest, **kwargs: Any):
425423
kwargs.pop(event_loop_fixture_id, None)
426424

427425
async def setup():
428-
res = await func(
429-
**_add_kwargs(func, kwargs, event_loop_fixture_id, event_loop, request)
430-
)
426+
res = await func(**_add_kwargs(func, kwargs, event_loop, request))
431427
return res
432428

433429
return event_loop.run_until_complete(setup())

0 commit comments

Comments
 (0)