diff --git a/python/tests/pyspark_integration/test_concurrent_write_s3_dynamo.py b/python/tests/pyspark_integration/test_concurrent_write_s3_dynamo.py index 185d2ed7eb..64479e96c8 100644 --- a/python/tests/pyspark_integration/test_concurrent_write_s3_dynamo.py +++ b/python/tests/pyspark_integration/test_concurrent_write_s3_dynamo.py @@ -183,6 +183,11 @@ def delete_dynamodb_table(table_name: str): @pytest.fixture def setup(): + os.environ['AWS_ENDPOINT_URL'] = 'http://localhost:4566' + os.environ['AWS_REGION'] = 'us-east-1' + os.environ['AWS_ACCESS_KEY_ID'] = 'deltalake' + os.environ['AWS_SECRET_ACCESS_KEY'] = 'weloverust' + os.environ['AWS_ALLOW_HTTP'] = 'true' id = uuid.uuid4() bucket_name = f"delta-rs-integration-{id}" bucket_url = f"s3://{bucket_name}"