@@ -27,7 +27,7 @@ executor = LocalExecutor
27
27
# Airflow, regardless of the worker count. Generally this value, multiplied by the number of
28
28
# schedulers in your cluster, is the maximum number of task instances with the running
29
29
# state in the metadata database.
30
- parallelism = 16
30
+ parallelism = 32
31
31
32
32
# The maximum number of task instances allowed to run concurrently in each DAG. To calculate
33
33
# the number of tasks that is running concurrently for a DAG, add up the number of running
@@ -76,7 +76,7 @@ dagbag_import_error_tracebacks = True
76
76
dagbag_import_error_traceback_depth = 2
77
77
78
78
# How long before timing out a DagFileProcessor, which processes a dag file
79
- dag_file_processor_timeout = 90
79
+ dag_file_processor_timeout = 50
80
80
81
81
# The class to use for running task instances in a subprocess.
82
82
# Choices include StandardTaskRunner, CgroupTaskRunner or the full import path to the class
@@ -926,11 +926,11 @@ scheduler_idle_sleep_time = 1
926
926
# Number of seconds after which a DAG file is parsed. The DAG file is parsed every
927
927
# ``min_file_process_interval`` number of seconds. Updates to DAGs are reflected after
928
928
# this interval. Keeping this number low will increase CPU usage.
929
- min_file_process_interval = 900
929
+ min_file_process_interval = 30
930
930
931
931
# How often (in seconds) to check for stale DAGs (DAGs which are no longer present in
932
932
# the expected files) which should be deactivated.
933
- deactivate_stale_dags_interval = 900
933
+ deactivate_stale_dags_interval = 60
934
934
935
935
# How often (in seconds) to scan the DAGs directory for new files. Default to 5 minutes.
936
936
dag_dir_list_interval = 300
0 commit comments