如何使用Azkaban Python API将流添加为Azkaban作业的依赖项？

Question

session = remote.Session("user@https://AZKABANURL")
workflows = session.get_workflows("FlowFProjectName")
flows = workflows[u"flows"]
flow_id = flows[0]["flowId"]

workflows = session.get_workflow_info("FlowFProjectName", flow_id)
node_id = workflows["nodes"][0]["id"]

现在我有了node_id，它是流F中最后一个作业的名称，我如何在作业a中添加流F的依赖项？是这样的吗？

jobs["A"] = {
    "type": "command", 
    "command": 'echo "Hello World"', 
    "dependencies": "F"
}

在上传到Azkaban（通过将此作业捆绑到项目中）时，执行以下操作会给我一个错误：

jobs[“a”]=Job（{“type”：“command”,“command”：“echo”hello world“,”dependencies“：node_id}）

azkaban.util.AzkabanError: Installation Failed.
Error found in upload. Cannot upload.
a cannot find dependency <node_id>

Answer 1

我找到了问题的答案：

1. 调用远程流并等待它完成（在while循环中）
2. 使用一个启动程序，使流F调用它的依赖作业。

选项1：更容易理解--使用while循环继续询问Azkaban某个特定的作业/流是否仍在运行。但是在这样做的时候，您应该让while循环运行一个小时又一个小时+检查流是否正在运行的方式是使用get_running_workflows()方法。此方法不返回流的某个实例是否仍在运行，而是只返回所述流的任何实例是否正在运行。