@@ -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 ():
@@ -59,6 +57,14 @@ def cmd_opts(request):
59
57
return ("--reactor={}" .format (reactor ),)
60
58
61
59
60
+ def test_inline_callbacks_in_pytest ():
61
+ assert hasattr (pytest , 'inlineCallbacks' )
62
+
63
+
64
+ def test_blockon_in_pytest ():
65
+ assert hasattr (pytest , 'blockon' )
66
+
67
+
62
68
def test_fail_later (testdir , cmd_opts ):
63
69
test_file = """
64
70
from twisted.internet import reactor, defer
@@ -284,8 +290,8 @@ def test_succeed(foo):
284
290
assert_outcomes (rr , {"passed" : 2 , "failed" : 3 })
285
291
286
292
287
- @ skip_if_reactor_not ( "default" )
288
- def test_blockon_in_hook ( testdir , cmd_opts ):
293
+ def test_blockon_in_hook ( testdir , cmd_opts , request ):
294
+ skip_if_reactor_not ( request , "default" )
289
295
conftest_file = """
290
296
import pytest_twisted as pt
291
297
from twisted.internet import reactor, defer
@@ -312,8 +318,8 @@ def test_succeed():
312
318
assert_outcomes (rr , {"passed" : 1 })
313
319
314
320
315
- @ skip_if_reactor_not ( "default" )
316
- def test_wrong_reactor ( testdir , cmd_opts ):
321
+ def test_wrong_reactor ( testdir , cmd_opts , request ):
322
+ skip_if_reactor_not ( request , "default" )
317
323
conftest_file = """
318
324
def pytest_addhooks():
319
325
import twisted.internet.reactor
@@ -329,8 +335,8 @@ def test_succeed():
329
335
assert "WrongReactorAlreadyInstalledError" in rr .stderr .str ()
330
336
331
337
332
- @ skip_if_reactor_not ( "qt5reactor" )
333
- def test_blockon_in_hook_with_qt5reactor ( testdir , cmd_opts ):
338
+ def test_blockon_in_hook_with_qt5reactor ( testdir , cmd_opts , request ):
339
+ skip_if_reactor_not ( request , "qt5reactor" )
334
340
conftest_file = """
335
341
import pytest_twisted as pt
336
342
import pytestqt
@@ -359,8 +365,8 @@ def test_succeed():
359
365
assert_outcomes (rr , {"passed" : 1 })
360
366
361
367
362
- @ skip_if_reactor_not ( "qt5reactor" )
363
- def test_wrong_reactor_with_qt5reactor ( testdir , cmd_opts ):
368
+ def test_wrong_reactor_with_qt5reactor ( testdir , cmd_opts , request ):
369
+ skip_if_reactor_not ( request , "qt5reactor" )
364
370
conftest_file = """
365
371
def pytest_addhooks():
366
372
import twisted.internet.default
@@ -376,8 +382,8 @@ def test_succeed():
376
382
assert "WrongReactorAlreadyInstalledError" in rr .stderr .str ()
377
383
378
384
379
- @ skip_if_reactor_not ( "default" )
380
- def test_pytest_from_reactor_thread ( testdir ):
385
+ def test_pytest_from_reactor_thread ( testdir , request ):
386
+ skip_if_reactor_not ( request , "default" )
381
387
test_file = """
382
388
import pytest
383
389
import pytest_twisted
0 commit comments