linter

mozilla · Sep 18, 2023 · c30433d · c30433d
1 parent 1e2b42e
commit c30433d
Show file tree

Hide file tree

Showing 12 changed files with 12 additions and 12 deletions.
diff --git a/dags/adm_export.py b/dags/adm_export.py
@@ -4,8 +4,8 @@
 from airflow.hooks.base import BaseHook
 from airflow.sensors.external_task import ExternalTaskSensor
 
-from utils.constants import ALLOWED_STATES, FAILED_STATES
 from operators.gcp_container_operator import GKEPodOperator
+from utils.constants import ALLOWED_STATES, FAILED_STATES
 from utils.tags import Tag
 
 DOCS = """\

diff --git a/dags/bhr_collection.py b/dags/bhr_collection.py
@@ -22,9 +22,9 @@
 from airflow.providers.amazon.aws.hooks.base_aws import AwsBaseHook
 from airflow.sensors.external_task import ExternalTaskSensor
 
+from operators.gcp_container_operator import GKEPodOperator
 from utils.constants import ALLOWED_STATES, FAILED_STATES
 from utils.dataproc import get_dataproc_parameters, moz_dataproc_pyspark_runner
-from operators.gcp_container_operator import GKEPodOperator
 from utils.tags import Tag
 
 default_args = {

diff --git a/dags/crash_symbolication.py b/dags/crash_symbolication.py
@@ -12,9 +12,9 @@
 from airflow.providers.amazon.aws.hooks.base_aws import AwsBaseHook
 from airflow.sensors.external_task import ExternalTaskSensor
 
+from operators.gcp_container_operator import GKEPodOperator
 from utils.constants import ALLOWED_STATES, FAILED_STATES
 from utils.dataproc import get_dataproc_parameters, moz_dataproc_pyspark_runner
-from operators.gcp_container_operator import GKEPodOperator
 from utils.tags import Tag
 
 default_args = {

diff --git a/dags/dim_active_users_aggregates.py b/dags/dim_active_users_aggregates.py
@@ -16,8 +16,8 @@
 from airflow.operators.empty import EmptyOperator
 from airflow.sensors.external_task import ExternalTaskSensor
 
-from utils.constants import ALLOWED_STATES, FAILED_STATES
 from operators.gcp_container_operator import GKEPodOperator
+from utils.constants import ALLOWED_STATES, FAILED_STATES
 from utils.tags import Tag
 
 default_args = {

diff --git a/dags/experiment_auto_sizing.py b/dags/experiment_auto_sizing.py
@@ -11,8 +11,8 @@
 from airflow import DAG
 from airflow.sensors.external_task import ExternalTaskSensor
 
-from utils.constants import ALLOWED_STATES, FAILED_STATES
 from operators.gcp_container_operator import GKEPodOperator
+from utils.constants import ALLOWED_STATES, FAILED_STATES
 from utils.tags import Tag
 
 default_args = {

diff --git a/dags/firefox_public_data_report.py b/dags/firefox_public_data_report.py
@@ -11,13 +11,13 @@
 from airflow.operators.subdag import SubDagOperator
 from airflow.sensors.external_task import ExternalTaskSensor
 
+from operators.gcp_container_operator import GKEPodOperator
 from utils.constants import ALLOWED_STATES, FAILED_STATES
 from utils.dataproc import (
     get_dataproc_parameters,
     moz_dataproc_pyspark_runner,
 )
 from utils.gcp import bigquery_etl_query
-from operators.gcp_container_operator import GKEPodOperator
 from utils.tags import Tag
 
 default_args = {

diff --git a/dags/glam_glean_imports.py b/dags/glam_glean_imports.py
@@ -7,8 +7,8 @@
 from airflow.sensors.external_task import ExternalTaskSensor
 from airflow.utils.task_group import TaskGroup
 
-from utils.constants import ALLOWED_STATES, FAILED_STATES
 from operators.gcp_container_operator import GKENatPodOperator
+from utils.constants import ALLOWED_STATES, FAILED_STATES
 from utils.tags import Tag
 
 default_args = {

diff --git a/dags/jetstream.py b/dags/jetstream.py
@@ -17,8 +17,8 @@
 from airflow import DAG
 from airflow.sensors.external_task import ExternalTaskSensor
 
-from utils.constants import ALLOWED_STATES, FAILED_STATES
 from operators.gcp_container_operator import GKEPodOperator
+from utils.constants import ALLOWED_STATES, FAILED_STATES
 from utils.tags import Tag
 
 default_args = {

diff --git a/dags/socorro_import.py b/dags/socorro_import.py
@@ -8,8 +8,8 @@
 from airflow.sensors.external_task import ExternalTaskMarker
 from airflow.utils.task_group import TaskGroup
 
-from utils.dataproc import moz_dataproc_pyspark_runner
 from operators.gcp_container_operator import GKEPodOperator
+from utils.dataproc import moz_dataproc_pyspark_runner
 from utils.tags import Tag
 
 """

diff --git a/dags/taar_daily.py b/dags/taar_daily.py
@@ -21,12 +21,12 @@
 from airflow.operators.subdag import SubDagOperator
 from airflow.sensors.external_task import ExternalTaskSensor
 
+from operators.gcp_container_operator import GKEPodOperator
 from utils.constants import ALLOWED_STATES, FAILED_STATES
 from utils.dataproc import (
     moz_dataproc_jar_runner,
     moz_dataproc_pyspark_runner,
 )
-from operators.gcp_container_operator import GKEPodOperator
 from utils.tags import Tag
 
 TAAR_ETL_STORAGE_BUCKET = Variable.get("taar_etl_storage_bucket")

diff --git a/dags/taar_weekly.py b/dags/taar_weekly.py
@@ -16,8 +16,8 @@
 from airflow.models import Variable
 from airflow.operators.subdag import SubDagOperator
 
-from utils.dataproc import moz_dataproc_pyspark_runner
 from operators.gcp_container_operator import GKEPodOperator
+from utils.dataproc import moz_dataproc_pyspark_runner
 from utils.tags import Tag
 
 taar_ensemble_cluster_name = "dataproc-taar-ensemble"

diff --git a/utils/gcp.py b/utils/gcp.py
@@ -14,8 +14,8 @@
     BigQueryToGCSOperator,
 )
 
-from utils.dataproc import get_dataproc_parameters
 from operators.gcp_container_operator import GKEPodOperator
+from utils.dataproc import get_dataproc_parameters
 
 GCP_PROJECT_ID = "moz-fx-data-airflow-gke-prod"
 DATAPROC_PROJECT_ID = "airflow-dataproc"