j-y-matsubara commented on a change in pull request #8757:
URL: https://github.com/apache/airflow/pull/8757#discussion_r422455491



##########
File path: docs/kubernetes.rst
##########
@@ -40,11 +40,44 @@ that has the ability to mutate pod objects before sending 
them to the Kubernetes
 for scheduling. It receives a single argument as a reference to pod objects, 
and
 is expected to alter its attributes.
 
-This could be used, for instance, to add sidecar or init containers
+This could be used, for instance, to add init containers

Review comment:
       How is it used for sidecar?
   We can mutation pod object by using pod_mutation_hook, but I think we can 
not add any containers (sidecars), excluding the init container ( in the case 
of using kubernetes_request_factory.py, pod object of argument of 
pod_mutation_hook is not V1Pod※. Overwrite **part of the contents of** req 
object, for example req['spec']['containers'][0]['image'] = pod.image , 
creating in pod_request_factory.py with pod object, and launch "Pod" based on 
req object. ).
   
   In the version 2.0, We can directly edit the pod object (V1Pod) used to 
launch "Pod". ( argument of pod_mutation_hook is V1Pod ) Therefore, we can add 
any containaers (sidecar).
   
   If my understanding is mistaken, please tell me.
   
   ※Supplementary information (version 1.10.10)
    If we set the following to the operator,
   ```
   k2 = KubernetesPodOperator(namespace='airflow01',
                              task_id='test-kwsk',
                              name='test-kwsk',
                              image="airflowworker:1.0.0",
                              image_pull_policy="IfNotPresent",
                              cmds=["bash", "-cx"],
                              arguments=['sleep 10000'],
                              do_xcom_push=True,
          ....
                             ..
   ```
   The pod object of argument of pod_mutation_hook is already set as follows.
   ```
   affinity:    {}
   annotations: {}
   args:        ['sleep 10000']
   cmds:        ['bash', '-cx']
   configmaps:  []
   dnspolicy:   None
   envs:        {}
   hostnetwork: False
   image:       airflowworker:1.0.0
   image_pull_policy:   IfNotPresent
   ...
   ..
   ```
   
   
   




----------------------------------------------------------------
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]


Reply via email to