Skip to content

Commit

Permalink
Update celery_executor.rst (apache#42741)
Browse files Browse the repository at this point in the history
* Update celery_executor.rst

Fix typo.

* Fix typos.

* Update docs/apache-airflow-providers-celery/celery_executor.rst

Co-authored-by: Shahar Epstein <60007259+shahar1@users.noreply.github.com>

---------

Co-authored-by: Shahar Epstein <60007259+shahar1@users.noreply.github.com>
  • Loading branch information
2 people authored and ellisms committed Nov 13, 2024
1 parent 420495a commit 9432c62
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions docs/apache-airflow-providers-celery/celery_executor.rst
Original file line number Diff line number Diff line change
Expand Up @@ -187,10 +187,10 @@ Two databases are also available:
- QueueBroker
- ResultBackend

During this process, two 2 process are created:
During this process, two processes are created:

- LocalTaskJobProcess - It logic is described by LocalTaskJob. It is monitoring RawTaskProcess. New processes are started using TaskRunner.
- RawTaskProcess - It is process with the user code e.g. :meth:`~airflow.models.baseoperator.BaseOperator.execute`.
- LocalTaskJobProcess - Its logic is described by LocalTaskJob. It is monitoring RawTaskProcess. New processes are started using TaskRunner.
- RawTaskProcess - It is a process with the user code e.g. :meth:`~airflow.models.baseoperator.BaseOperator.execute`.

| [1] **SchedulerProcess** processes the tasks and when it finds a task that needs to be done, sends it to the **QueueBroker**.
| [2] **SchedulerProcess** also begins to periodically query **ResultBackend** for the status of the task.
Expand Down

0 comments on commit 9432c62

Please sign in to comment.