【问题标题】:Subprocess doesn't work as expected with Apache Airflow子流程无法按预期与 Apache Airflow 一起工作
【发布时间】:2022-01-19 17:42:43
【问题描述】:

为了了解这个模块的工作原理,我一直在测试模板文件的子进程,并且我做了许多测试,从与“主”文件相同的目录中调用文件并从不同目录调用文件,一切顺利。

当尝试将此模块集成到 Airflow 系统上时,子进程永远无法获取我正在搜索的文件并且它不会给出任何错误。 在这种特殊情况下,我试图从“simple_dag.py”文件中调用“test.py”脚本。但是,我似乎无法理解为什么它不执行该方法。

您是否曾经在气流“环境”中运行子进程时遇到过问题?你知道我该如何解决这个问题吗? 谢谢。

这是文件的代码:

To see the code click here

【问题讨论】:

  • 从屏幕截图中输入代码不方便。请以正确的格式粘贴。

标签: python subprocess airflow


【解决方案1】:

在你的 pythonOperator 中尝试python_callable = _my_name()

【讨论】:

    猜你喜欢
    • 2012-02-19
    • 2019-12-14
    • 1970-01-01
    • 2019-09-04
    • 1970-01-01
    • 2022-01-05
    • 1970-01-01
    • 2019-09-06
    • 2016-05-15
    相关资源
    最近更新 更多