我们有一种方法可以在工作中指定重试,如下所示
from azkaban import Job, Project
project = Project('azkaban_basic_flow', root=__file__)
project.properties['retries'] = '3' #line 3
project.properties['retry.backoff'] = '60000' #line 4
假设我们有10个项目-我们需要对所有10个项目的第3行和第4行进行硬编码。有什么方法可以启用默认重试机制,以便默认情况下可以将其继承到所有项目。
最佳答案
全局级别的属性应该在common.properties中定义,并且可以在azkaban项目中使用。(azkaban-version:3.1.0)
遵循的步骤:
导航到azkaban-exec-server-0.1.0-SNAPSHOT / plugins / jobtypes /并创建common.properties
将内容放入common.properties retries=3retry.backoff=30000
使用azkaban-exec-server-0.1.0-SNAPSHOT / plugins / jobtypes / jobtype-name / plugin.properties中common.properties中定义的属性。
重新启动azkaban-executor以反映更改。
现在可以使用${retries}
和${retry.backoff}
在azkaban项目内部访问该属性
参考文档:azkaban documentation