@@ -541,6 +541,7 @@ def test_categorical(self, pa):
541
541
expected = df .astype (object )
542
542
check_round_trip (df , pa , expected = expected )
543
543
544
+ @pytest .mark .single
544
545
def test_s3_roundtrip_explicit_fs (self , df_compat , s3_resource , pa , s3so ):
545
546
s3fs = pytest .importorskip ("s3fs" )
546
547
if LooseVersion (pyarrow .__version__ ) <= LooseVersion ("0.17.0" ):
@@ -555,6 +556,7 @@ def test_s3_roundtrip_explicit_fs(self, df_compat, s3_resource, pa, s3so):
555
556
write_kwargs = kw ,
556
557
)
557
558
559
+ @pytest .mark .single
558
560
def test_s3_roundtrip (self , df_compat , s3_resource , pa ):
559
561
if LooseVersion (pyarrow .__version__ ) <= LooseVersion ("0.17.0" ):
560
562
pytest .skip ()
@@ -563,6 +565,7 @@ def test_s3_roundtrip(self, df_compat, s3_resource, pa):
563
565
564
566
@td .skip_if_no ("s3fs" )
565
567
@pytest .mark .parametrize ("partition_col" , [["A" ], []])
568
+ @pytest .mark .single
566
569
def test_s3_roundtrip_for_dir (self , df_compat , s3_resource , pa , partition_col ):
567
570
# GH #26388
568
571
expected_df = df_compat .copy ()
@@ -761,6 +764,7 @@ def test_filter_row_groups(self, fp):
761
764
result = read_parquet (path , fp , filters = [("a" , "==" , 0 )])
762
765
assert len (result ) == 1
763
766
767
+ @pytest .mark .single
764
768
def test_s3_roundtrip (self , df_compat , s3_resource , fp ):
765
769
# GH #19134
766
770
check_round_trip (df_compat , fp , path = "s3://pandas-test/fastparquet.parquet" )
0 commit comments