Task was destroyed but it is pending! even after awaiting it
I wrote the following factory fixture that creates a ReconnectingConsumer and then awaits it to stop:
TypeError: object async_generator can’t be used in ‘await’ expression when using pytest async factory fixture
I’m trying to define an async factory fixture that creates a ReconnectingConsumer object and then awaits it to stop, like this: