Skip to content

Commit

Permalink
Fix linter issues
Browse files Browse the repository at this point in the history
  • Loading branch information
ifoukarakis committed Oct 23, 2024
1 parent c83a068 commit c41e8dd
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 15 deletions.
5 changes: 1 addition & 4 deletions airflow/dags/mattermost_dags/transformation/dbt.py
Original file line number Diff line number Diff line change
@@ -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
Expand Down
12 changes: 6 additions & 6 deletions airflow/dags/mattermost_dags/transformation/dbt_nightly.py
Original file line number Diff line number Diff line change
@@ -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, **{}}

Expand Down
10 changes: 5 additions & 5 deletions airflow/dags/mattermost_dags/transformation/deferred_merge.py
Original file line number Diff line number Diff line change
@@ -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, **{}}

Expand Down

0 comments on commit c41e8dd

Please sign in to comment.