Update execution delta

dags/bqetl_activity_stream.py

@@ -36,7 +36,7 @@ with DAG(
         task_id="wait_for_copy_deduplicate_copy_deduplicate_all",
         external_dag_id="copy_deduplicate",
         external_task_id="copy_deduplicate_all",
-        execution_delta=datetime.timedelta(days=-1, seconds=82800),
+        execution_delta=datetime.timedelta(seconds=3600),
         check_existence=True,
         mode="reschedule",
         dag=dag,

dags/bqetl_addons.py

@@ -97,7 +97,7 @@ with DAG(
         task_id="wait_for_copy_deduplicate_copy_deduplicate_main_ping",
         external_dag_id="copy_deduplicate",
         external_task_id="copy_deduplicate_main_ping",
-        execution_delta=datetime.timedelta(days=-1, seconds=82800),
+        execution_delta=datetime.timedelta(seconds=3600),
         check_existence=True,
         mode="reschedule",
         dag=dag,

dags/bqetl_amo_stats.py

@@ -113,7 +113,7 @@ with DAG(
         task_id="wait_for_copy_deduplicate_copy_deduplicate_all",
         external_dag_id="copy_deduplicate",
         external_task_id="copy_deduplicate_all",
-        execution_delta=datetime.timedelta(days=-1, seconds=82800),
+        execution_delta=datetime.timedelta(seconds=3600),
         check_existence=True,
         mode="reschedule",
         dag=dag,
@@ -131,7 +131,7 @@ with DAG(
         task_id="wait_for_copy_deduplicate_copy_deduplicate_main_ping",
         external_dag_id="copy_deduplicate",
         external_task_id="copy_deduplicate_main_ping",
-        execution_delta=datetime.timedelta(days=-1, seconds=82800),
+        execution_delta=datetime.timedelta(seconds=3600),
         check_existence=True,
         mode="reschedule",
         dag=dag,

dags/bqetl_core.py

@@ -46,7 +46,7 @@ with DAG("bqetl_core", default_args=default_args, schedule_interval="0 2 * * *")
         task_id="wait_for_copy_deduplicate_copy_deduplicate_all",
         external_dag_id="copy_deduplicate",
         external_task_id="copy_deduplicate_all",
-        execution_delta=datetime.timedelta(days=-1, seconds=82800),
+        execution_delta=datetime.timedelta(seconds=3600),
         check_existence=True,
         mode="reschedule",
         dag=dag,

dags/bqetl_gud.py

@@ -138,7 +138,7 @@ with DAG("bqetl_gud", default_args=default_args, schedule_interval="0 2 * * *")
         task_id="wait_for_copy_deduplicate_baseline_clients_last_seen",
         external_dag_id="copy_deduplicate",
         external_task_id="baseline_clients_last_seen",
-        execution_delta=datetime.timedelta(days=-1, seconds=82800),
+        execution_delta=datetime.timedelta(seconds=3600),
         check_existence=True,
         mode="reschedule",
         dag=dag,

dags/bqetl_main_summary.py

@@ -44,7 +44,7 @@ with DAG(
         task_id="wait_for_copy_deduplicate_copy_deduplicate_main_ping",
         external_dag_id="copy_deduplicate",
         external_task_id="copy_deduplicate_main_ping",
-        execution_delta=datetime.timedelta(days=-1, seconds=82800),
+        execution_delta=datetime.timedelta(seconds=3600),
         check_existence=True,
         mode="reschedule",
         dag=dag,

dags/bqetl_messaging_system.py

@@ -132,7 +132,7 @@ with DAG(
         task_id="wait_for_copy_deduplicate_copy_deduplicate_all",
         external_dag_id="copy_deduplicate",
         external_task_id="copy_deduplicate_all",
-        execution_delta=datetime.timedelta(days=-1, seconds=82800),
+        execution_delta=datetime.timedelta(seconds=3600),
         check_existence=True,
         mode="reschedule",
         dag=dag,

dags/bqetl_mobile_search.py

@@ -48,7 +48,7 @@ with DAG(
         task_id="wait_for_copy_deduplicate_copy_deduplicate_all",
         external_dag_id="copy_deduplicate",
         external_task_id="copy_deduplicate_all",
-        execution_delta=datetime.timedelta(days=-1, seconds=82800),
+        execution_delta=datetime.timedelta(seconds=3600),
         check_existence=True,
         mode="reschedule",
         dag=dag,

dags/bqetl_nondesktop.py

@@ -71,7 +71,7 @@ with DAG(
         task_id="wait_for_copy_deduplicate_baseline_clients_last_seen",
         external_dag_id="copy_deduplicate",
         external_task_id="baseline_clients_last_seen",
-        execution_delta=datetime.timedelta(days=-1, seconds=82800),
+        execution_delta=datetime.timedelta(seconds=3600),
         check_existence=True,
         mode="reschedule",
         dag=dag,

dags/bqetl_vrbrowser.py

@@ -76,7 +76,7 @@ with DAG(
         task_id="wait_for_copy_deduplicate_copy_deduplicate_all",
         external_dag_id="copy_deduplicate",
         external_task_id="copy_deduplicate_all",
-        execution_delta=datetime.timedelta(days=-1, seconds=82800),
+        execution_delta=datetime.timedelta(seconds=3600),
         check_existence=True,
         mode="reschedule",
         dag=dag,

sql/activity_stream_bi/impression_stats_flat_v1/metadata.yaml

@@ -10,4 +10,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: copy_deduplicate_all
-      execution_delta: -1h
+      execution_delta: 1h

sql/amo_prod/desktop_addons_by_client_v1/metadata.yaml

@@ -13,4 +13,4 @@ scheduling:
   depends_on:
     - task_id: copy_deduplicate_main_ping
       dag_name: copy_deduplicate
-      execution_delta: -1h
+      execution_delta: 1h

sql/amo_prod/fenix_addons_by_client_v1/metadata.yaml

@@ -14,4 +14,4 @@ scheduling:
   depends_on:
     - task_id: copy_deduplicate_all
       dag_name: copy_deduplicate
-      execution_delta: -1h
+      execution_delta: 1h

sql/messaging_system_derived/cfr_users_daily_v1/metadata.yaml

@@ -9,4 +9,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: copy_deduplicate_all
-      execution_delta: -1h
+      execution_delta: 1h

sql/messaging_system_derived/onboarding_users_daily_v1/metadata.yaml

@@ -9,4 +9,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: copy_deduplicate_all
-      execution_delta: -1h
+      execution_delta: 1h

sql/messaging_system_derived/snippets_users_daily_v1/metadata.yaml

@@ -9,4 +9,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: copy_deduplicate_all
-      execution_delta: -1h
+      execution_delta: 1h

sql/org_mozilla_vrbrowser_derived/baseline_daily_v1/metadata.yaml

@@ -13,4 +13,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: copy_deduplicate_all
-      execution_delta: -1h
+      execution_delta: 1h

sql/org_mozilla_vrbrowser_derived/metrics_daily_v1/metadata.yaml

@@ -13,4 +13,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: copy_deduplicate_all
-      execution_delta: -1h
+      execution_delta: 1h

sql/search_derived/mobile_search_clients_daily_v1/metadata.yaml

@@ -11,4 +11,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: copy_deduplicate_all
-      execution_delta: -1h
+      execution_delta: 1h

sql/telemetry_derived/addon_aggregates_v2/metadata.yaml

@@ -13,4 +13,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: copy_deduplicate_main_ping
-      execution_delta: -1h
+      execution_delta: 1h

sql/telemetry_derived/addon_names_v1/metadata.yaml

@@ -16,4 +16,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: copy_deduplicate_main_ping
-      execution_delta: -1h
+      execution_delta: 1h

sql/telemetry_derived/addons_v2/metadata.yaml

@@ -11,4 +11,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: copy_deduplicate_main_ping
-      execution_delta: -1h
+      execution_delta: 1h

sql/telemetry_derived/core_clients_daily_v1/metadata.yaml

@@ -11,4 +11,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: copy_deduplicate_all
-      execution_delta: -1h
+      execution_delta: 1h

sql/telemetry_derived/firefox_nondesktop_day_2_7_activation_v1/metadata.yaml

@@ -14,4 +14,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: baseline_clients_last_seen
-      execution_delta: -1h
+      execution_delta: 1h

sql/telemetry_derived/firefox_nondesktop_exact_mau28_by_client_count_dimensions_v1/metadata.yaml

@@ -13,4 +13,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: baseline_clients_last_seen
-      execution_delta: -1h
+      execution_delta: 1h

sql/telemetry_derived/firefox_nondesktop_exact_mau28_v1/metadata.yaml

@@ -12,4 +12,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: baseline_clients_last_seen
-      execution_delta: -1h
+      execution_delta: 1h

sql/telemetry_derived/main_summary_v4/metadata.yaml

@@ -12,4 +12,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: copy_deduplicate_main_ping
-      execution_delta: -1h
+      execution_delta: 1h

sql/telemetry_derived/smoot_usage_nondesktop_v2/metadata.yaml

@@ -12,4 +12,4 @@ scheduling:
   depends_on:
     - dag_name: copy_deduplicate
       task_id: baseline_clients_last_seen
-      execution_delta: -1h
+      execution_delta: 1h