timeout

Travigo · Dec 20, 2024 · 79de998 · 79de998
1 parent aa627d9
commit 79de998
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/airflow/dags/batch-data-import.py b/airflow/dags/batch-data-import.py
@@ -54,6 +54,7 @@ def generate_job(name : str, command : str, instance_size : str = "small", taskg
       container_resources=container_resources,
       trigger_rule="all_done",
       task_group=taskgroup,
+      startup_timeout_seconds=7200,
     #   on_success_callback=[
     #     send_slack_webhook_notification(
     #         slack_webhook_conn_id="slack-dataimport",