Skip to content

Commit

Permalink
remove test
Browse files Browse the repository at this point in the history
  • Loading branch information
samster25 committed May 7, 2024
1 parent 8bc7961 commit d12cb6e
Showing 1 changed file with 1 addition and 15 deletions.
16 changes: 1 addition & 15 deletions tests/integration/io/parquet/test_reads_public_data.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
from pyarrow import parquet as pq

import daft
from daft.exceptions import ConnectTimeoutError, DaftCoreException, ReadTimeoutError
from daft.exceptions import ConnectTimeoutError, ReadTimeoutError
from daft.filesystem import get_filesystem, get_protocol_from_path
from daft.table import MicroPartition, Table

Expand Down Expand Up @@ -437,17 +437,3 @@ def test_read_timeout(multithreaded_io):

with pytest.raises((ReadTimeoutError, ConnectTimeoutError), match=f"timed out when trying to connect to {url}"):
MicroPartition.read_parquet(url, io_config=read_timeout_config, multithreaded_io=multithreaded_io).to_arrow()


@pytest.mark.integration()
@pytest.mark.parametrize(
"multithreaded_io",
[False, True],
)
def test_bad_profile_name(multithreaded_io):
PROFILE_NAME = "SOME_RANDOM_PROFILE"
url = "s3://daft-public-data/test_fixtures/parquet-dev/mvp.parquet"
read_timeout_config = daft.io.IOConfig(s3=daft.io.S3Config(profile_name=PROFILE_NAME, region_name="us-west-2"))

with pytest.raises(DaftCoreException, match=f"could not find source profile {PROFILE_NAME}"):
MicroPartition.read_parquet(url, io_config=read_timeout_config, multithreaded_io=multithreaded_io).to_arrow()

0 comments on commit d12cb6e

Please sign in to comment.