@@ -31,12 +31,10 @@ def format_run_result_output_for_assert(run_result):
31
31
)
32
32
33
33
34
- def skip_if_reactor_not (expected_reactor ):
35
- actual_reactor = pytest .config .getoption ("reactor" , "default" )
36
- return pytest .mark .skipif (
37
- actual_reactor != expected_reactor ,
38
- reason = "reactor is {} not {}" .format (actual_reactor , expected_reactor ),
39
- )
34
+ def skip_if_reactor_not (request , expected_reactor ):
35
+ actual_reactor = request .config .getoption ("reactor" , "default" )
36
+ if actual_reactor != expected_reactor :
37
+ pytest .skip ("reactor is {} not {}" .format (actual_reactor , expected_reactor ))
40
38
41
39
42
40
def skip_if_no_async_await ():
@@ -52,6 +50,22 @@ def cmd_opts(request):
52
50
return ("--reactor={}" .format (reactor ),)
53
51
54
52
53
+ def test_inline_callbacks_in_pytest ():
54
+ assert hasattr (pytest , 'inlineCallbacks' )
55
+
56
+
57
+ def test_blockon_in_pytest ():
58
+ assert hasattr (pytest , 'blockon' )
59
+
60
+
61
+ def test_async_yield_in_pytest ():
62
+ assert hasattr (pytest , 'async_yield' )
63
+
64
+
65
+ def test_async_await_in_pytest ():
66
+ assert hasattr (pytest , 'async_await' )
67
+
68
+
55
69
def test_async_yield_is_inlineCallbacks ():
56
70
assert pytest_twisted .async_yield is pytest_twisted .inlineCallbacks
57
71
@@ -226,8 +240,8 @@ async def test_succeed(foo):
226
240
assert_outcomes (rr , {"passed" : 2 , "failed" : 1 })
227
241
228
242
229
- @ skip_if_reactor_not ( "default" )
230
- def test_blockon_in_hook ( testdir , cmd_opts ):
243
+ def test_blockon_in_hook ( testdir , cmd_opts , request ):
244
+ skip_if_reactor_not ( request , "default" )
231
245
conftest_file = """
232
246
import pytest_twisted as pt
233
247
from twisted.internet import reactor, defer
@@ -254,8 +268,8 @@ def test_succeed():
254
268
assert_outcomes (rr , {"passed" : 1 })
255
269
256
270
257
- @ skip_if_reactor_not ( "default" )
258
- def test_wrong_reactor ( testdir , cmd_opts ):
271
+ def test_wrong_reactor ( testdir , cmd_opts , request ):
272
+ skip_if_reactor_not ( request , "default" )
259
273
conftest_file = """
260
274
def pytest_addhooks():
261
275
import twisted.internet.reactor
@@ -271,8 +285,8 @@ def test_succeed():
271
285
assert "WrongReactorAlreadyInstalledError" in rr .stderr .str ()
272
286
273
287
274
- @ skip_if_reactor_not ( "qt5reactor" )
275
- def test_blockon_in_hook_with_qt5reactor ( testdir , cmd_opts ):
288
+ def test_blockon_in_hook_with_qt5reactor ( testdir , cmd_opts , request ):
289
+ skip_if_reactor_not ( request , "qt5reactor" )
276
290
conftest_file = """
277
291
import pytest_twisted as pt
278
292
import pytestqt
@@ -301,8 +315,8 @@ def test_succeed():
301
315
assert_outcomes (rr , {"passed" : 1 })
302
316
303
317
304
- @ skip_if_reactor_not ( "qt5reactor" )
305
- def test_wrong_reactor_with_qt5reactor ( testdir , cmd_opts ):
318
+ def test_wrong_reactor_with_qt5reactor ( testdir , cmd_opts , request ):
319
+ skip_if_reactor_not ( request , "qt5reactor" )
306
320
conftest_file = """
307
321
def pytest_addhooks():
308
322
import twisted.internet.default
@@ -318,8 +332,8 @@ def test_succeed():
318
332
assert "WrongReactorAlreadyInstalledError" in rr .stderr .str ()
319
333
320
334
321
- @ skip_if_reactor_not ( "default" )
322
- def test_pytest_from_reactor_thread ( testdir ):
335
+ def test_pytest_from_reactor_thread ( testdir , request ):
336
+ skip_if_reactor_not ( request , "default" )
323
337
test_file = """
324
338
import pytest
325
339
import pytest_twisted
0 commit comments