Skip to content

Commit aca2606

Browse files
committed
chore: use os.getenv and default value
Signed-off-by: derek1032 <dchang@health2sync.com>
1 parent f8e9802 commit aca2606

1 file changed

Lines changed: 6 additions & 25 deletions

File tree

  • sdk/python/feast/infra/offline_stores/contrib/athena_offline_store/tests

sdk/python/feast/infra/offline_stores/contrib/athena_offline_store/tests/data_source.py

Lines changed: 6 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -27,31 +27,12 @@ class AthenaDataSourceCreator(DataSourceCreator):
2727

2828
def __init__(self, project_name: str, *args, **kwargs):
2929
super().__init__(project_name)
30-
region = (
31-
os.environ.get("ATHENA_REGION")
32-
if os.environ.get("ATHENA_REGION")
33-
else "ap-northeast-2"
34-
)
35-
data_source = (
36-
os.environ.get("ATHENA_DATA_SOURCE")
37-
if os.environ.get("ATHENA_DATA_SOURCE")
38-
else "AwsDataCatalog"
39-
)
40-
database = (
41-
os.environ.get("ATHENA_DATABASE")
42-
if os.environ.get("ATHENA_DATABASE")
43-
else "default"
44-
)
45-
workgroup = (
46-
os.environ.get("ATHENA_WORKGROUP")
47-
if os.environ.get("ATHENA_WORKGROUP")
48-
else "primary"
49-
)
50-
bucket_name = (
51-
os.environ.get("ATHENA_S3_BUCKET_NAME")
52-
if os.environ.get("ATHENA_S3_BUCKET_NAME")
53-
else "feast-integration-tests"
54-
)
30+
31+
region = os.getenv("ATHENA_REGION", "ap-northeast-2")
32+
data_source = os.getenv("ATHENA_DATA_SOURCE", "AwsDataCatalog")
33+
database = os.getenv("ATHENA_DATABASE", "default")
34+
workgroup = os.getenv("ATHENA_WORKGROUP", "primary")
35+
bucket_name = os.getenv("ATHENA_S3_BUCKET_NAME", "feast-integration-tests")
5536

5637
self.client = aws_utils.get_athena_data_client(region)
5738
self.s3 = aws_utils.get_s3_resource(region)

0 commit comments

Comments
 (0)