I have submitted a patch:
https://github.com/apache/incubator-airflow/pull/3442
--
Craig
On 2018/05/30 19:45:23, Craig Rodrigues <crodr...@gmail.com> wrote:
> Oh, OK, I just saw this in example_kubernetes_operator.py:
>
> try:
> # Kubernetes is optional, so not available in vanilla Airflow
> # pip install airflow[gcp]
> from airflow.contrib.operators.kubernetes_pod_operator import
> KubernetesPodOperator
> except ImportError:
> # Just import the BaseOperator as the KubernetesPodOperator
> logging.warn("Could not import KubernetesPodOperator")
> from airflow.models import BaseOperator as KubernetesPodOperator
>
> That code is just bad and confusing for an example!!
>
> --
> Craig
