From c41e8dd40efc217aeffa3a7c0ce4215955cfbbe5 Mon Sep 17 00:00:00 2001 From: Ioannis Foukarakis Date: Wed, 23 Oct 2024 13:39:36 +0300 Subject: [PATCH] Fix linter issues --- airflow/dags/mattermost_dags/transformation/dbt.py | 5 +---- .../mattermost_dags/transformation/dbt_nightly.py | 12 ++++++------ .../mattermost_dags/transformation/deferred_merge.py | 10 +++++----- 3 files changed, 12 insertions(+), 15 deletions(-) diff --git a/airflow/dags/mattermost_dags/transformation/dbt.py b/airflow/dags/mattermost_dags/transformation/dbt.py index 12092b6f4..c4dbb6554 100644 --- a/airflow/dags/mattermost_dags/transformation/dbt.py +++ b/airflow/dags/mattermost_dags/transformation/dbt.py @@ -1,10 +1,7 @@ from datetime import datetime, timedelta from mattermost_dags.airflow_utils import MATTERMOST_DATAWAREHOUSE_IMAGE, pod_defaults, pod_env_vars, send_alert -from mattermost_dags.kube_secrets import ( - DBT_CLOUD_API_ACCOUNT_ID, - DBT_CLOUD_API_KEY, -) +from mattermost_dags.kube_secrets import DBT_CLOUD_API_ACCOUNT_ID, DBT_CLOUD_API_KEY from airflow import DAG from airflow.providers.cncf.kubernetes.operators.pod import KubernetesPodOperator diff --git a/airflow/dags/mattermost_dags/transformation/dbt_nightly.py b/airflow/dags/mattermost_dags/transformation/dbt_nightly.py index 62c2d2d9b..e9ca929c5 100644 --- a/airflow/dags/mattermost_dags/transformation/dbt_nightly.py +++ b/airflow/dags/mattermost_dags/transformation/dbt_nightly.py @@ -1,22 +1,22 @@ from datetime import datetime, timedelta -from airflow import DAG -from airflow.providers.cncf.kubernetes.operators.pod import KubernetesPodOperator -from airflow.utils.trigger_rule import TriggerRule - from mattermost_dags.airflow_utils import MATTERMOST_DATAWAREHOUSE_IMAGE, pod_defaults, pod_env_vars, send_alert from mattermost_dags.kube_secrets import ( DBT_CLOUD_API_ACCOUNT_ID, DBT_CLOUD_API_KEY, SNOWFLAKE_ACCOUNT, - SNOWFLAKE_USER, SNOWFLAKE_PASSWORD, SNOWFLAKE_TRANSFORM_DATABASE, + SNOWFLAKE_TRANSFORM_LARGE_WAREHOUSE, SNOWFLAKE_TRANSFORM_ROLE, SNOWFLAKE_TRANSFORM_WAREHOUSE, - SNOWFLAKE_TRANSFORM_LARGE_WAREHOUSE, + SNOWFLAKE_USER, ) +from airflow import DAG +from airflow.providers.cncf.kubernetes.operators.pod import KubernetesPodOperator +from airflow.utils.trigger_rule import TriggerRule + # Load the env vars into a dict and set Secrets env_vars = {**pod_env_vars, **{}} diff --git a/airflow/dags/mattermost_dags/transformation/deferred_merge.py b/airflow/dags/mattermost_dags/transformation/deferred_merge.py index 8e8225231..524f5b8cc 100644 --- a/airflow/dags/mattermost_dags/transformation/deferred_merge.py +++ b/airflow/dags/mattermost_dags/transformation/deferred_merge.py @@ -1,18 +1,18 @@ from datetime import datetime, timedelta -from airflow import DAG -from airflow.providers.cncf.kubernetes.operators.pod import KubernetesPodOperator - from mattermost_dags.airflow_utils import MATTERMOST_DATAWAREHOUSE_IMAGE, pod_defaults, pod_env_vars, send_alert from mattermost_dags.kube_secrets import ( SNOWFLAKE_ACCOUNT, - SNOWFLAKE_USER, SNOWFLAKE_PASSWORD, SNOWFLAKE_TRANSFORM_DATABASE, - SNOWFLAKE_TRANSFORM_ROLE, SNOWFLAKE_TRANSFORM_LARGE_WAREHOUSE, + SNOWFLAKE_TRANSFORM_ROLE, + SNOWFLAKE_USER, ) +from airflow import DAG +from airflow.providers.cncf.kubernetes.operators.pod import KubernetesPodOperator + # Load the env vars into a dict and set Secrets env_vars = {**pod_env_vars, **{}}