@@ -115,7 +115,6 @@ def test_to_pandas_batches_w_correct_dtypes(scalars_df_default_index):
115
115
pd .testing .assert_series_equal (actual , expected )
116
116
117
117
118
- @pytest .mark .skip (reason = "Disable to unblock kokoro tests" )
119
118
@pytest .mark .parametrize (
120
119
("index" ),
121
120
[True , False ],
@@ -154,6 +153,7 @@ def test_to_csv_index(
154
153
dtype = dtype ,
155
154
date_format = {"timestamp_col" : "YYYY-MM-DD HH:MM:SS Z" },
156
155
index_col = index_col ,
156
+ storage_options = dict (expand = True ),
157
157
)
158
158
convert_pandas_dtypes (gcs_df , bytes_col = True )
159
159
gcs_df .index .name = scalars_df .index .name
@@ -164,7 +164,6 @@ def test_to_csv_index(
164
164
pd .testing .assert_frame_equal (gcs_df , scalars_pandas_df )
165
165
166
166
167
- @pytest .mark .skip (reason = "Disable to unblock kokoro tests" )
168
167
def test_to_csv_tabs (
169
168
scalars_dfs : Tuple [bigframes .dataframe .DataFrame , pd .DataFrame ],
170
169
gcs_folder : str ,
@@ -194,6 +193,7 @@ def test_to_csv_tabs(
194
193
dtype = dtype ,
195
194
date_format = {"timestamp_col" : "YYYY-MM-DD HH:MM:SS Z" },
196
195
index_col = index_col ,
196
+ storage_options = dict (expand = True ),
197
197
)
198
198
convert_pandas_dtypes (gcs_df , bytes_col = True )
199
199
gcs_df .index .name = scalars_df .index .name
@@ -415,7 +415,6 @@ def test_to_json_index_invalid_lines(
415
415
scalars_df .to_json (path , index = index )
416
416
417
417
418
- @pytest .mark .skip (reason = "Disable to unblock kokoro tests" )
419
418
@pytest .mark .parametrize (
420
419
("index" ),
421
420
[True , False ],
@@ -435,7 +434,12 @@ def test_to_json_index_records_orient(
435
434
""" Test the `to_json` API with `orient` is `records` and `lines` is True"""
436
435
scalars_df .to_json (path , index = index , orient = "records" , lines = True )
437
436
438
- gcs_df = pd .read_json (path , lines = True , convert_dates = ["datetime_col" ])
437
+ gcs_df = pd .read_json (
438
+ path ,
439
+ lines = True ,
440
+ convert_dates = ["datetime_col" ],
441
+ storage_options = dict (expand = True ),
442
+ )
439
443
convert_pandas_dtypes (gcs_df , bytes_col = True )
440
444
if index and scalars_df .index .name is not None :
441
445
gcs_df = gcs_df .set_index (scalars_df .index .name )
0 commit comments