OSDir


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: KubernetesPodOperator: Invalid arguments were passed to BaseOperator


I have submitted a patch:

https://github.com/apache/incubator-airflow/pull/3442

--
Craig

On 2018/05/30 19:45:23, Craig Rodrigues <crodr001@xxxxxxxxx> 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