eladkal commented on code in PR #72863:
URL: https://github.com/apache/airflow/pull/72863#discussion_r3984910612
##########
providers/cncf/kubernetes/docs/kubernetes_executor.rst:
##########
@@ -38,6 +38,25 @@ KubernetesExecutor requires a non-sqlite database in the
backend.
When a Dag submits a task, the KubernetesExecutor requests a worker pod from
the Kubernetes API. The worker pod then runs the task, reports the result, and
terminates.
+What the worker pod runs
+------------------------
+
+Airflow 3 removed the ``airflow worker`` command, and a worker image does not
need a
+replacement for it. The KubernetesExecutor injects the task into the ``base``
container's
+``args``, and the image's own entrypoint runs it:
+
+.. code-block:: text
+
+ args:
+ - python
+ - -m
+ - airflow.sdk.execution_time.execute_workload
+ - --json-string
+ - '{"token": "...", "dag_rel_path": "...", "ti": {...}, "type":
"ExecuteTask"}'
+
+Leave ``command`` unset on the ``base`` container: setting it replaces this
entrypoint and
+the task never runs.
Review Comment:
lets write this in Airflow 2.11 vs Airflow 3.
The idea is that at some point we will drop Airflow 2.11 support from the
provider and in that point we will adjust the doc explain existing state rather
than migration between 2->3
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
