dimberman commented on a change in pull request #10956:
URL: https://github.com/apache/airflow/pull/10956#discussion_r491140287
##########
File path: airflow/jobs/scheduler_job.py
##########
@@ -1464,23 +1070,21 @@ def _execute_task_instances(
2. Change the state for the TIs above atomically.
3. Enqueue the TIs in the executor.
- :param simple_dag_bag: TaskInstances associated with DAGs in the
- simple_dag_bag will be fetched from the DB and executed
- :type simple_dag_bag: airflow.utils.dag_processing.SimpleDagBag
+ HA note: This function is a "critical section" meaning that only a
single executor process can execute
+ this function at the same time. This is achived by doing ``SELECT ...
from pool FOR UPDATE``. For DBs
Review comment:
```suggestion
this function at the same time. This is achieved by doing ``SELECT
... from pool FOR UPDATE``. For DBs
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
