我有一个任务，它生成哪些文件应该被处理： def run(self): def output(self):我有一个包装器<em
浏览 3提问于2018-01-24得票数 2
回答已采纳
考虑一个任务通过动态依赖关系依赖于另一个任务的情况： import luigi
class TaskA使用luigi.run()接口，这是可行的。如您所见，TaskA有两个参数：parent=TaskB和arg=1。此外，还通过使用语法--TaskB-arg为TaskB提供了<
浏览 25提问于2020-11-15得票数 1
1回答
基于文档：<code>C0</code>我如何才能从Luigi.build而不是命令行来做到这一点？我的问题是，我有任务a，需要任务b，需要任务c；任务</em
浏览 15提问于2020-11-20得票数 1
1回答
我对路易吉完全陌生，我已经有了一个我似乎无法解决的问题。
我希望有人能帮我，我会非常感激！
事先致以最良好的问候和感谢
浏览 1提问于2018-02-07得票数 2
回答已采纳
在Luigi中，我有一个任务，在该任务中，我希望根据来自另一个上游任务的输出动态生成依赖项列表。例如： param = IntParameter()
def main(self): def output(self)p in TaskB().output()]
总之，我正在根据来自TaskA的输出在TaskC中创建一组
浏览 1提问于2019-10-30得票数 1
回答已采纳
1回答
我最近实现了一个luigi管道来处理我们其中一个生物信息学管道的处理。然而，关于如何设置这些任务，有一些基本的东西我并不了解。/ taskC -> taskB -> taskA\ taskC -&g
浏览 1提问于2017-10-07得票数 1
每一项Luigi任务都有两种基本方法--其中包括：关于以下内容，文档并不清楚:如果requires下定义的任务已经存在，那么output会发生什么情况？具体而言，让我们创建一个虚拟任务 def run(self): yield TaskA()
yield Taskb(
浏览 12提问于2022-01-28得票数 0
1回答
我有两个luigi任务。在TaskB中，我想对json和pickle.dump()进行一些转换。@inherits(TaskA) def requires(self):
args = {....}但是我得到的却是：<_io.
浏览 2提问于2020-01-29得票数 0
我的任务如下： def program_args(self): def program_environment(self): return env
shell脚本正在正常运行在此之后，如果我尝试运行任何其他任务，这些任务<
浏览 0提问于2018-12-03得票数 1
回答已采纳
我正在与Luigi中的一个我不理解的错误作斗争。我不知道这是一个已知的问题，Luigi的限制还是我做错了什么。 我使用Luigi来解决一个有很多任务和很多依赖项的实际问题。然而，我已经做了一个玩具示例，在这个示例中这个问题看起来很清楚。 让我们考虑两个任务，TaskA和TaskB，TaskA需要执行具有不同Luigi</
浏览 13提问于2021-01-20得票数 2
1回答
对Luigi问题的理解
、、、
看看ATask类 config = luigi.Parameter()
#Some Tasks maybe
return luigi.LocalTarget("A.txt")
f.write(&
浏览 13提问于2022-02-14得票数 0
1回答
我已经在Luigi中建立了一个任务管道。由于此管道将在不同的上下文中使用，因此可能需要在管道的开始或结束处包含更多任务，甚至任务之间的依赖关系完全不同。这时我想：“嘿，为什么要在我的配置文件中声明任务之间的依赖关系呢？”所以我在我的config.py中添加了类似这样的内容：
PIPELINE_DEPENDENC
浏览 5提问于2017-03-03得票数 8
我正在尝试动态创建Luigi任务(基于cmdList中的属性)，并将前面的任务作为下一个任务的依赖项。SQLTask是Luigi.Task的子类。然而，当我运行这段代码时，我得到了This progress looks :| because there were tasks that were not granted run permissionclass BDX_Task(SQLTask):
浏览 0提问于2019-04-06得票数 2
回答已采纳
1回答
我有以下设置 yield TaskB()Did not find any results and will exit
因为它找不到来自TaskB在s3上编写的任何结果。然后，TaskB实际上完成了它
浏览 5提问于2021-11-02得票数 0
1回答
这是我第二次尝试理解如何在Luigi中将参数传递给依赖项。第一个是here。 我的想法是:我有依赖于TaskB的TaskC，它依赖于TaskA，它依赖于Task0。我希望整个序列始终是完全相同的，除了我希望能够控制Task0读取的文件，让我们称之为path。Luigi的哲学通常是每个任务应该只知道它所依赖的任务及其参数。它们就在那里，这样示例就可以成功运行
浏览 10提问于2020-11-23得票数 3
我刚刚尝试运行文档中的python luigi ： def output(self): def requires(self):
defou
浏览 1提问于2015-07-17得票数 2
2回答
所以我有两个任务(假设是TaskA和TaskB)。我希望这两个任务都每小时运行一次，但TaskB需要TaskA。TaskB没有任何参数，但是TaskA有两个参数，分别表示日期和小时。如果我在命令行上运行TaskB，我需要向它传递参数吗？
浏览 16提问于2016-08-18得票数 0
如果某个条件不满足，我会尝试使用onlyIf()停止任务的执行。有没有一种方法可以停止任务依赖关系的执行？看起来onlyIf并没有阻止依赖项的执行。在下面的示例中，当我将executeMe参数作为false传递时，我希望不执行taskA。build.gradle doFirst {
println 'executing taskA&#x
浏览 17提问于2015-08-29得票数 1
1回答
我的TaskB需要TaskA，在完成时，TaskA写入MySQL表，然后TaskB将此输出作为表的输入。
我似乎想不出在路易吉该怎么做。有人能给我举个例子或者给我举个简单的例子吗？
浏览 6提问于2016-11-03得票数 4
回答已采纳
我有许多芹菜节点运行在不同的Linux机器上。简化的集群如下所示：
我有一个长期运行的taskA，它从远程文件服务器下载一个(巨大的)文件，我想在taskB在同一台机器上完成它的工作后触发taskB，因为taskA就是在那里下载的文件，基本上是对请注意图表中的taskA on nodeA在同一个节点上触发taskB，而在nodeB上运行<e
浏览 0提问于2016-05-09得票数 1
回答已采纳
云服务器
ICP备案
实时音视频
即时通信 IM
云直播
腾讯云开发者
