force

airflow/dags/acs_condition.py

@@ -1,4 +1,4 @@
-# Ignore the Airflow module, it is installed in both dev and prod
+# Ignore the Airflow module, it is installed in both dev & prod
 from airflow import DAG  # pylint: disable = no-name-in-module
 from airflow.utils.dates import days_ago  # pylint: disable = no-name-in-module
 import util
@@ -18,7 +18,6 @@
 )
 
 # CACHE ACS SOURCE INTO TMP JSON IN BUCKETS
-
 # acs_condition_gcs_payload_2012 = util.generate_gcs_payload(_ACS_WORKFLOW_ID, year='2012')
 # acs_condition_gcs_operator_2012 = util.create_gcs_ingest_operator(
 #     'acs_condition_to_gcs_2012', acs_condition_gcs_payload_2012, data_ingestion_dag