From 7a9b2d182ee3acffc2f6a3e76785dbbcbb7e37e7 Mon Sep 17 00:00:00 2001 From: Dmitry Dementev Date: Wed, 10 Dec 2025 18:49:49 +0300 Subject: [PATCH] =?UTF-8?q?=D0=9F=D1=80=D0=B8=D0=BD=D0=B5=D1=81=D0=B5?= =?UTF-8?q?=D0=BD=20isort?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- airflow/dags/bookings_stg_ddl.py | 3 ++- airflow/dags/bookings_to_gp_stage.py | 2 +- airflow/dags/csv_to_greenplum_dq.py | 3 ++- airflow/dags/ddl_greenplum_base.py | 3 ++- pyproject.toml | 4 ++++ 5 files changed, 11 insertions(+), 4 deletions(-) diff --git a/airflow/dags/bookings_stg_ddl.py b/airflow/dags/bookings_stg_ddl.py index fa7dd68..ff6032c 100644 --- a/airflow/dags/bookings_stg_ddl.py +++ b/airflow/dags/bookings_stg_ddl.py @@ -7,9 +7,10 @@ from __future__ import annotations from datetime import datetime, timedelta -from airflow import DAG from airflow.providers.postgres.operators.postgres import PostgresOperator +from airflow import DAG + GREENPLUM_CONN_ID = "greenplum_conn" default_args = {"owner": "airflow", "retries": 1, "retry_delay": timedelta(seconds=30)} diff --git a/airflow/dags/bookings_to_gp_stage.py b/airflow/dags/bookings_to_gp_stage.py index 4724671..de4df21 100644 --- a/airflow/dags/bookings_to_gp_stage.py +++ b/airflow/dags/bookings_to_gp_stage.py @@ -12,10 +12,10 @@ from __future__ import annotations from datetime import datetime, timedelta -from airflow import DAG from airflow.operators.python import PythonOperator from airflow.providers.postgres.operators.postgres import PostgresOperator +from airflow import DAG default_args = { "owner": "airflow", diff --git a/airflow/dags/csv_to_greenplum_dq.py b/airflow/dags/csv_to_greenplum_dq.py index b127005..02ae600 100644 --- a/airflow/dags/csv_to_greenplum_dq.py +++ b/airflow/dags/csv_to_greenplum_dq.py @@ -3,7 +3,6 @@ from __future__ import annotations import logging from datetime import datetime, timedelta -from airflow import DAG from airflow.operators.python import PythonOperator from helpers.greenplum import ( assert_orders_have_rows, @@ -13,6 +12,8 @@ from helpers.greenplum import ( get_gp_conn, ) +from airflow import DAG + def _run_check(check_callable): """ diff --git a/airflow/dags/ddl_greenplum_base.py b/airflow/dags/ddl_greenplum_base.py index 7c2d4d7..2ab4986 100644 --- a/airflow/dags/ddl_greenplum_base.py +++ b/airflow/dags/ddl_greenplum_base.py @@ -7,9 +7,10 @@ from __future__ import annotations from datetime import datetime, timedelta -from airflow import DAG from airflow.providers.postgres.operators.postgres import PostgresOperator +from airflow import DAG + GREENPLUM_CONN_ID = "greenplum_conn" default_args = {"owner": "airflow", "retries": 1, "retry_delay": timedelta(seconds=30)} diff --git a/pyproject.toml b/pyproject.toml index 74af620..b8afbbb 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -14,3 +14,7 @@ dev = [ "psycopg2-binary==2.9.9", "pytest==7.4.4", ] + +[tool.isort] +profile = "black" +src_paths = ["airflow", "tests"]