我对来自KubernetesPodOperator的Airflow感到困惑,我想知道如何传递load_users_into_table()函数,因为它在Pod中的connection of Airflow中存储了一个conn_id参数。在官方文档中,建议将conn_id放在Secret中,但我不明白在此之后如何在函数load_users_into_table()中传递它。要在pod中</em
我试图使用KubernetesPodOperator在开发iMac (10.15.6)机器上进行测试。用于minikube和kubectl的版本如下所示。气流版使用apache-airflow[kubernetes]==1.10.11
我无法使用KubernetesPodOperator运行任何豆荚。我有两个问题。如果我设置kubernetes.config.config_exception.ConfigException: Service host&
我已经在库伯奈特星系团中建立了气流。要运行任务,我使用的是KubernetesPodOperator。logging_mixin.py:95} INFO - [2019-01-27 12:45:21,641] {jobs.py:2614} INFO - Task is not able to be rundo_som