@@ -75,7 +75,8 @@ def resolve_reporters(self, info):
75
75
pytest .skip ('SQL batching only works for SQLAlchemy 1.2+' , allow_module_level = True )
76
76
77
77
78
- def test_many_to_one (session_factory ):
78
+ @pytest .mark .asyncio
79
+ async def test_many_to_one (session_factory ):
79
80
session = session_factory ()
80
81
81
82
reporter_1 = Reporter (
@@ -103,7 +104,7 @@ def test_many_to_one(session_factory):
103
104
with mock_sqlalchemy_logging_handler () as sqlalchemy_logging_handler :
104
105
# Starts new session to fully reset the engine / connection logging level
105
106
session = session_factory ()
106
- result = schema .execute ("""
107
+ result = await schema .execute_async ("""
107
108
query {
108
109
articles {
109
110
headline
@@ -166,7 +167,8 @@ def test_many_to_one(session_factory):
166
167
}
167
168
168
169
169
- def test_one_to_one (session_factory ):
170
+ @pytest .mark .asyncio
171
+ async def test_one_to_one (session_factory ):
170
172
session = session_factory ()
171
173
172
174
reporter_1 = Reporter (
@@ -194,7 +196,7 @@ def test_one_to_one(session_factory):
194
196
with mock_sqlalchemy_logging_handler () as sqlalchemy_logging_handler :
195
197
# Starts new session to fully reset the engine / connection logging level
196
198
session = session_factory ()
197
- result = schema .execute ("""
199
+ result = await schema .execute_async ("""
198
200
query {
199
201
reporters {
200
202
firstName
@@ -257,7 +259,8 @@ def test_one_to_one(session_factory):
257
259
}
258
260
259
261
260
- def test_one_to_many (session_factory ):
262
+ @pytest .mark .asyncio
263
+ async def test_one_to_many (session_factory ):
261
264
session = session_factory ()
262
265
263
266
reporter_1 = Reporter (
@@ -293,7 +296,7 @@ def test_one_to_many(session_factory):
293
296
with mock_sqlalchemy_logging_handler () as sqlalchemy_logging_handler :
294
297
# Starts new session to fully reset the engine / connection logging level
295
298
session = session_factory ()
296
- result = schema .execute ("""
299
+ result = await schema .execute_async ("""
297
300
query {
298
301
reporters {
299
302
firstName
@@ -382,7 +385,8 @@ def test_one_to_many(session_factory):
382
385
}
383
386
384
387
385
- def test_many_to_many (session_factory ):
388
+ @pytest .mark .asyncio
389
+ async def test_many_to_many (session_factory ):
386
390
session = session_factory ()
387
391
388
392
reporter_1 = Reporter (
@@ -420,7 +424,7 @@ def test_many_to_many(session_factory):
420
424
with mock_sqlalchemy_logging_handler () as sqlalchemy_logging_handler :
421
425
# Starts new session to fully reset the engine / connection logging level
422
426
session = session_factory ()
423
- result = schema .execute ("""
427
+ result = await schema .execute_async ("""
424
428
query {
425
429
reporters {
426
430
firstName
@@ -586,7 +590,8 @@ def resolve_reporters(self, info):
586
590
assert len (select_statements ) == 2
587
591
588
592
589
- def test_connection_factory_field_overrides_batching_is_false (session_factory ):
593
+ @pytest .mark .asyncio
594
+ async def test_connection_factory_field_overrides_batching_is_false (session_factory ):
590
595
session = session_factory ()
591
596
reporter_1 = Reporter (first_name = 'Reporter_1' )
592
597
session .add (reporter_1 )
@@ -620,7 +625,7 @@ def resolve_reporters(self, info):
620
625
with mock_sqlalchemy_logging_handler () as sqlalchemy_logging_handler :
621
626
# Starts new session to fully reset the engine / connection logging level
622
627
session = session_factory ()
623
- schema .execute ("""
628
+ await schema .execute_async ("""
624
629
query {
625
630
reporters {
626
631
articles {
0 commit comments