diff --git a/dags/airlfow-db-cleanup.py b/dags/airlfow-db-cleanup.py index d3486cc..a4f7940 100644 --- a/dags/airlfow-db-cleanup.py +++ b/dags/airlfow-db-cleanup.py @@ -13,8 +13,17 @@ import airflow from airflow import settings from airflow.configuration import conf -from airflow.models import (DAG, DagModel, DagRun, DagTag, Log, SlaMiss, - TaskInstance, Variable, XCom) +from airflow.models import ( + DAG, + DagModel, + DagRun, + DagTag, + Log, + SlaMiss, + TaskInstance, + Variable, + XCom, +) try: from airflow.jobs import BaseJob diff --git a/dags/ods/google_search_console/dag.py b/dags/ods/google_search_console/dag.py index 2c15468..9b98e0b 100644 --- a/dags/ods/google_search_console/dag.py +++ b/dags/ods/google_search_console/dag.py @@ -5,8 +5,7 @@ from airflow import DAG from airflow.operators.python_operator import PythonOperator -from ods.google_search_console.udfs.google_search import \ - GoogleSearchConsoleReporter +from ods.google_search_console.udfs.google_search import GoogleSearchConsoleReporter DEFAULT_ARGS = { "owner": "davidtnfsh", diff --git a/dags/ods/kktix_ticket_orders/udfs/kktix_refund.py b/dags/ods/kktix_ticket_orders/udfs/kktix_refund.py index ba6a4c1..7e4d2ab 100644 --- a/dags/ods/kktix_ticket_orders/udfs/kktix_refund.py +++ b/dags/ods/kktix_ticket_orders/udfs/kktix_refund.py @@ -4,8 +4,10 @@ from google.cloud import bigquery from ods.kktix_ticket_orders.udfs.bigquery_loader import TABLE -from ods.kktix_ticket_orders.udfs.kktix_api import (_get_attendance_book_id, - _get_attendee_ids) +from ods.kktix_ticket_orders.udfs.kktix_api import ( + _get_attendance_book_id, + _get_attendee_ids, +) CLIENT = bigquery.Client(project=os.getenv("BIGQUERY_PROJECT")) diff --git a/tests/test_cakeresume_uploader.py b/tests/test_cakeresume_uploader.py index fcac18e..f694402 100644 --- a/tests/test_cakeresume_uploader.py +++ b/tests/test_cakeresume_uploader.py @@ -1,8 +1,7 @@ import csv from pathlib import Path -from contrib.survey_cake.udfs.survey_cake_csv_uploader import \ - SurveyCakeCSVUploader +from contrib.survey_cake.udfs.survey_cake_csv_uploader import SurveyCakeCSVUploader def test_cakeresume_uploader() -> None: