由于我们将airflow从v1.8.1升级到v1.10.1,因此由SSHOperator执行的ssh命令不再显示在日志中。现在你有了日志; Subtask: Output:
<the output of your ssh command> 在你得到命令+已执行命令的输出之前。在日志中记录命令来调试您的任务是很好的。
我在DAG运行时生成命令,因为命令的一些参数取决于用户传递的参数。正如我从文档中读到的,KubernetesPodOperator需要字符串列表或jinja模板列表: :param arguments: arguments of the entrypoint.我有PythonOperator,它生成命令并将其推送到XCOM和KubernetesPodOperator,在这两个命令的参数中,我传递由Python