You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Roster (Jira)" <ji...@apache.org> on 2020/04/14 08:33:00 UTC

[jira] [Commented] (AIRFLOW-6996) Control KubernetesExecutor delete_worker_pods setting per task

    [ https://issues.apache.org/jira/browse/AIRFLOW-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082989#comment-17082989 ] 

Roster commented on AIRFLOW-6996:
---------------------------------

is it smart to allow such free overwrite?
In some companies you don't want programmers to overwrite what devops set as expected behavior.

> Control KubernetesExecutor delete_worker_pods setting per task
> --------------------------------------------------------------
>
>                 Key: AIRFLOW-6996
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-6996
>             Project: Apache Airflow
>          Issue Type: Improvement
>          Components: executor-kubernetes
>    Affects Versions: 2.0.0, 1.10.9
>            Reporter: Barend
>            Assignee: Daniel Imberman
>            Priority: Major
>
> h3. Context
> The global {{airflow.cfg}} defines a boolean flag that controls whether the KubernetesExecutor should delete worker pods:
> {code:none}
> [kubernetes]
> # If True (default), worker pods will be deleted upon termination
> delete_worker_pods = True
> {code}
> You generally want this flag to be {{True}}, unless diagnosing specific kinds of task launch problems.
> It's currently an all-or-nothing setting that affects all tasks in all DAGs.
> h3. Improvement
> When including a task in a DAG, I have the option to provide executor configuration specifically for that task:
> {code:python}
> sometask = DummyOperator(
>         task_id="example",
>         executor_config={ "KubernetesExecutor": { "image": "..." }  }
> )
> {code}
> This does not currently (v1.10.9) give me the option to override pod deletion for that specific task. I think this would be an improvement for two reasons:
>  # you're generally stopping deletion to debug the launch of a specifc task, making this the tightest possible scope where you'd want to control this behaviour
>  # you can control the setting without restarting Airflow, by reloading the DAG



--
This message was sent by Atlassian Jira
(v8.3.4#803005)