用于在luigi中编写动态、灵活的工作流的助手库
sciluigi的Python项目详细描述
工作流代码快速演示
*有关10分钟的简短屏幕广播,请参阅下面的基本内容 `此链接<;https://www.youtube.com/watch?v=gkkuwskrbjw>;`
只是为了快速了解工作流定义的外观 在sciluigi中,检查这个代码示例(impl隐藏任务修正 为了简洁起见。有关更多详细信息,请参见下面的使用部分:
importsciluigiasslclassMyWorkflow(sl.WorkflowTask):defworkflow(self):# Initialize tasks:foowrt=self.new_task('foowriter',MyFooWriter)foorpl=self.new_task('fooreplacer',MyFooReplacer,replacement='bar')# Here we do the *magic*: Connecting outputs to inputs:foorpl.in_foo=foowrt.out_foo# Return the last task(s) in the workflow chain.returnfoorpl
就这样!同样,请参阅下面的"用法"部分了解更多 详细说明如何做到这一点!