@@ -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