2828from nwbinspector .tools import make_minimal_nwbfile
2929from nwbinspector .utils import FilePathType
3030
31- DISABLE_STREAMING_TESTS , DISABLE_STREAMING_TESTS_REASON = check_streaming_tests_enabled ()
31+ STREAMING_TESTS_ENABLED , DISABLED_STREAMING_TESTS_REASON = check_streaming_tests_enabled ()
3232
3333
3434def add_big_dataset_no_compression (nwbfile : NWBFile ):
@@ -560,7 +560,7 @@ def test_inspect_nwb_dandi_config(self):
560560 self .assertCountEqual (first = test_results , second = true_results )
561561
562562
563- @pytest .mark .skipif (DISABLE_STREAMING_TESTS , reason = "Needs h5py setup with ROS3. " )
563+ @pytest .mark .skipif (not STREAMING_TESTS_ENABLED , reason = DISABLED_STREAMING_TESTS_REASON or " " )
564564def test_dandiset_streaming ():
565565 messages = list (inspect_all (path = "000126" , select = ["check_subject_species_exists" ], stream = True ))
566566 assert messages [0 ] == InspectorMessage (
@@ -574,7 +574,7 @@ def test_dandiset_streaming():
574574 )
575575
576576
577- @pytest .mark .skipif (DISABLE_STREAMING_TESTS , reason = "Needs h5py setup with ROS3. " )
577+ @pytest .mark .skipif (not STREAMING_TESTS_ENABLED , reason = DISABLED_STREAMING_TESTS_REASON or " " )
578578def test_dandiset_streaming_parallel ():
579579 messages = list (inspect_all (path = "000126" , select = ["check_subject_species_exists" ], stream = True , n_jobs = 2 ))
580580 assert messages [0 ] == InspectorMessage (
@@ -588,7 +588,7 @@ def test_dandiset_streaming_parallel():
588588 )
589589
590590
591- @pytest .mark .skipif (DISABLE_STREAMING_TESTS , reason = DISABLE_STREAMING_TESTS_REASON or "" )
591+ @pytest .mark .skipif (not STREAMING_TESTS_ENABLED , reason = DISABLED_STREAMING_TESTS_REASON or "" )
592592class TestStreamingCLI (TestCase ):
593593 @classmethod
594594 def setUpClass (cls ):
0 commit comments