@@ -158,7 +158,7 @@ async def aio_connection(endpoint, database):
158158
159159
160160@pytest .fixture ()
161- async def driver (endpoint , database , event_loop ):
161+ async def driver (endpoint , database ):
162162 driver_config = ydb .DriverConfig (
163163 endpoint ,
164164 database ,
@@ -173,7 +173,7 @@ async def driver(endpoint, database, event_loop):
173173
174174
175175@pytest .fixture ()
176- async def driver_sync (endpoint , database , event_loop ):
176+ async def driver_sync (endpoint , database ):
177177 driver_config = ydb .DriverConfig (
178178 endpoint ,
179179 database ,
@@ -261,7 +261,6 @@ def topic_consumer():
261261
262262
263263@pytest .fixture ()
264- @pytest .mark .asyncio ()
265264async def topic_path (driver , topic_consumer , database ) -> str :
266265 topic_path = database + "/test-topic"
267266
@@ -279,7 +278,6 @@ async def topic_path(driver, topic_consumer, database) -> str:
279278
280279
281280@pytest .fixture ()
282- @pytest .mark .asyncio ()
283281async def topic2_path (driver , topic_consumer , database ) -> str :
284282 topic_path = database + "/test-topic2"
285283
@@ -297,7 +295,6 @@ async def topic2_path(driver, topic_consumer, database) -> str:
297295
298296
299297@pytest .fixture ()
300- @pytest .mark .asyncio ()
301298async def topic_with_two_partitions_path (driver , topic_consumer , database ) -> str :
302299 topic_path = database + "/test-topic-two-partitions"
303300
@@ -317,7 +314,6 @@ async def topic_with_two_partitions_path(driver, topic_consumer, database) -> st
317314
318315
319316@pytest .fixture ()
320- @pytest .mark .asyncio ()
321317async def topic_with_messages (driver , topic_consumer , database ):
322318 topic_path = database + "/test-topic-with-messages"
323319 try :
@@ -348,7 +344,6 @@ async def topic_with_messages(driver, topic_consumer, database):
348344
349345
350346@pytest .fixture ()
351- @pytest .mark .asyncio ()
352347async def topic_with_messages_with_metadata (driver , topic_consumer , database ):
353348 topic_path = database + "/test-topic-with-messages-with-metadata"
354349 try :
@@ -373,7 +368,6 @@ async def topic_with_messages_with_metadata(driver, topic_consumer, database):
373368
374369
375370@pytest .fixture ()
376- @pytest .mark .asyncio ()
377371async def topic_reader (driver , topic_consumer , topic_path ) -> ydb .TopicReaderAsyncIO :
378372 reader = driver .topic_client .reader (topic = topic_path , consumer = topic_consumer )
379373 yield reader
0 commit comments