sokojh commented on code in PR #72863:
URL: https://github.com/apache/airflow/pull/72863#discussion_r3986016914
##########
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:
Done, split into 2.11 and 3 blocks so the 2.11 half can just be dropped when
provider support for it goes.
(Both arg lists are copied from worker pods I ran: 2.11.1 via the official
chart, 3.3.1 via `breeze k8s deploy-airflow --executor KubernetesExecutor`.)
--
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]
