@@ -316,16 +316,15 @@ def _synchronize_async_fixture(
316316def _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