@@ -1659,6 +1659,7 @@ def file_info(file: File) -> FileInfo:
1659
1659
assert len (all_dogs ) == 2
1660
1660
1661
1661
1662
+ @pytest .mark .xdist_group (name = "upload" )
1662
1663
def test_to_from_csv_remote (cloud_test_catalog_upload ):
1663
1664
ctc = cloud_test_catalog_upload
1664
1665
path = f"{ ctc .src_uri } /test.csv"
@@ -1672,6 +1673,7 @@ def test_to_from_csv_remote(cloud_test_catalog_upload):
1672
1673
assert df_equal (df1 , df )
1673
1674
1674
1675
1676
+ @pytest .mark .xdist_group (name = "upload" )
1675
1677
@pytest .mark .parametrize ("chunk_size" , (1000 , 2 ))
1676
1678
@pytest .mark .parametrize ("kwargs" , ({}, {"compression" : "gzip" }))
1677
1679
def test_to_from_parquet_remote (cloud_test_catalog_upload , chunk_size , kwargs ):
@@ -1688,6 +1690,7 @@ def test_to_from_parquet_remote(cloud_test_catalog_upload, chunk_size, kwargs):
1688
1690
assert df_equal (df1 , df )
1689
1691
1690
1692
1693
+ @pytest .mark .xdist_group (name = "upload" )
1691
1694
def test_to_from_parquet_partitioned_remote (cloud_test_catalog_upload ):
1692
1695
ctc = cloud_test_catalog_upload
1693
1696
path = f"{ ctc .src_uri } /parquets"
@@ -1743,6 +1746,7 @@ def test_from_json_jmespath(tmp_dir, test_session):
1743
1746
assert df_equal (df1 , df )
1744
1747
1745
1748
1749
+ @pytest .mark .xdist_group (name = "upload" )
1746
1750
# These deprecation warnings occur in the datamodel-code-generator package.
1747
1751
@pytest .mark .filterwarnings ("ignore::pydantic.warnings.PydanticDeprecatedSince20" )
1748
1752
def test_to_from_json_remote (cloud_test_catalog_upload ):
@@ -1759,6 +1763,7 @@ def test_to_from_json_remote(cloud_test_catalog_upload):
1759
1763
assert df_equal (df1 , df )
1760
1764
1761
1765
1766
+ @pytest .mark .xdist_group (name = "upload" )
1762
1767
# These deprecation warnings occur in the datamodel-code-generator package.
1763
1768
@pytest .mark .filterwarnings ("ignore::pydantic.warnings.PydanticDeprecatedSince20" )
1764
1769
def test_to_from_jsonl_remote (cloud_test_catalog_upload ):
0 commit comments