From c7e33e9567c905e4f46d8bcc5edb7601e4509370 Mon Sep 17 00:00:00 2001 From: Ioannis Foukarakis Date: Wed, 20 Mar 2024 16:28:24 +0200 Subject: [PATCH] MM-57113: fix region env var assignment --- airflow/dags/mattermost_dags/extract/push_proxy_new.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/airflow/dags/mattermost_dags/extract/push_proxy_new.py b/airflow/dags/mattermost_dags/extract/push_proxy_new.py index 7f3300824..21c4e5e71 100644 --- a/airflow/dags/mattermost_dags/extract/push_proxy_new.py +++ b/airflow/dags/mattermost_dags/extract/push_proxy_new.py @@ -71,7 +71,7 @@ def push_proxy_loader(): env_vars={}, arguments=[ "push_proxy PUSH_PROXY_LOGS_TEST_NEW LOGS_TEST_NEW " - " --prefix /AWSLogs/{{ var.value.push_proxy_aws_account_id }}/elasticloadbalancing/{{ var.value.push_proxy_aws_region_eu }}" + " --prefix /AWSLogs/{{ var.value.push_proxy_aws_account_id }}/elasticloadbalancing/{{ var.value.push_proxy_aws_region }}" " -s {{ var.value.push_proxy_target_schema }}" " -a ${SNOWFLAKE_ACCOUNT}" " -d ${SNOWFLAKE_LOAD_DATABASE}" @@ -98,7 +98,7 @@ def push_proxy_loader(): env_vars={}, arguments=[ "push_proxy PUSH_PROXY_LOGS_EU_NEW LOGS_EU_NEW " - " --prefix /AWSLogs/{{ var.value.push_proxy_aws_account_id }}/elasticloadbalancing/{{ var.value.push_proxy_aws_region }}" + " --prefix /AWSLogs/{{ var.value.push_proxy_aws_account_id }}/elasticloadbalancing/{{ var.value.push_proxy_aws_region_eu }}" " -s {{ var.value.push_proxy_target_schema }}" " -a ${SNOWFLAKE_ACCOUNT}" " -d ${SNOWFLAKE_LOAD_DATABASE}"