回答情况：
提问时间：
问题标签：
我正在使用luigi.build方法尝试luigi的多处理能力。但是我在执行的时候遇到了一些库错误。 custid= luigi.Parameter() def output(self):
return luigi.LocalTarget("logs/"+
浏览 16修改于2019-04-16得票数 0
error: can't copy 'luigi\static\visualiser\lib\URI.js': doesn't exist or not a regular file
Failed building wheel for luigiFailedto build luigi
Installing collected pac
浏览 2修改于2017-02-13得票数 3
回答已采纳
我运行的是Windows7，Python 2.7 via Anaconda 4.3.17，Luigi 2.4.0，Pandas 0.18，sklearn版本0.18。(most recent call last): File "C:\Anaconda2\lib\site-packages\luigi-2.4.0
浏览 0提问于2017-06-07得票数 6
回答已采纳
1回答
对于我的luigi工作流，我使用的配置文件类似于以下内容：[logging]disable_existing_loggerscontrib configurationsmarker-table="luigi_table_updates"LUIGI_CONFIG_PATH='path/to/luig
浏览 1提问于2019-04-25得票数 4
我有以下任务 foo = luigi.DictParameter(default = {})
luigi --模块my_tasks MyTask --标记{“角色”："web"我不得不说，Luigi是我工作过的最糟糕的项目之一。
浏览 17修改于2022-05-04得票数 0
2回答
我曾尝试在luigi类调用的一个函数(get_target_path)中定义全局变量，但当我返回Luigi管道时，该全局变量似乎无法持久存在。这就是我的代码的样子： """ """ date = luigi.Parameter(default=dat
浏览 0提问于2018-07-03得票数 3
1回答
我正在尝试为我的luigi任务创建一个别名。通常，要调用它，我会键入luigi --module myTask --parameters cats然而，当我再次尝试使用别名调用我的任务时，我得到了这个错误: luigi.task_register.TaskClassNot
浏览 0提问于2016-01-14得票数 2
2回答
当我运行luigi任务时，有时会遇到框架崩溃，导致以下任务全部失败。在这里，错误日志信息：2017-10-05 22:02()
File "/home/develop/data_warehouse/venv/local/lib/python2.7/site-packages/luigi&
浏览 3修改于2017-10-13得票数 2
在luigi.Task.run中，我们需要将对象序列化为文件/数据库/等等： param = luigi.Parameter() AnotherTask(self.param) luigi.LocalTarget('out_{}'.format有没有像这样在luigi中自动实例化的方法？：
Ano
浏览 1修改于2016-06-03得票数 0
回答已采纳
我正在用luigi构建数据流，我想要的是一个接一个地将文件读入unicode字符串，清理它们，最后将它们写入一些新的UTF-8文件中。问题是，在run类的CleanText方法中，我似乎无法在luigi.LocalTarget中使用unicode。任何想法都将不胜感激！这是我的代码：import os """
Checks which(root + sel
浏览 2提问于2015-09-07得票数 1
回答已采纳
1回答
我在配置luigi每任务重试策略时遇到问题。我已经按如下方式配置了全局luigi.cfg文件：retry-delay: 1keep_alive: true此外，它在luigi配置手册中指出，编写任务如下：只需覆盖luigi.cfg中指定的luigi
浏览 15提问于2016-09-20得票数 2
1回答
看看ATask类 config = luigi.Parameter()
#Some Tasks maybe
return luigi.LocalTarget("A.txt")
浏览 13提问于2022-02-14得票数 0
没有FinalTask实例期望class FinalTask (luigi.Task): defexc.communicate() def output(self):
return luigi.LocalTarget
浏览 1提问于2017-06-29得票数 3
回答已采纳
2回答
我有一个读取.sql文件并输出到BigQuery的luigi任务。我的问题是，有没有方法可以在不同的.sql文件中重用相同的任务，而不必复制整个luigi任务，即我想要创建模板luigi任务的实例。class run_sql(luigi.task):
sql_file = 'path/to/sql/file' # This is the only bit of code that changes
浏览 4修改于2019-03-03得票数 1
回答已采纳
标准的luigi.file.LocalTarget对于处理参数有一种非常天真的方法，在文档的示例中也显示了这一点： return luigi.LocalTarget下面是参数搜索的非常简单的想法：class Sum(luigi.Task):
list_ = luigi.Parameter()
of = luigi.Para
浏览 1提问于2016-10-12得票数 2
我已经将一组luigi任务打包到一个包中。目前，每个etl- luigi.cfg在同一目录下都有自己的任务，但是由于所有这些.cfg文件都是相同的，所以看起来不太理想。从软件包中为luigi设置默认/常规配置的最佳方式是什么？
看起来luigi.Config和luigi.interface.core包很有前途，但我仍然不确定我需要在哪里执行/启动它们。
浏览 0提问于2017-12-06得票数 3
回答已采纳
我试图理解luigi是如何工作的，我理解了这个想法，但是实际的实现要困难一些;)这就是我所拥有的： return OtherTask(self.x)
print(self.x)
def
浏览 0提问于2016-09-14得票数 7
回答已采纳
我正在使用luigi执行一系列任务，如下所示： stuff = luigi.Parameter()
with self.output().open('w') as f:
class Task2(<
浏览 0提问于2018-04-24得票数 5
class Download(Task):
return LocalTarget("data/user_{0}.tar.bz2".format(self.date_interval))
#import pdb; pdb.set_trace()
SENTENCE_URL = 'http://downloads.org/expor
浏览 15提问于2017-03-13得票数 2
回答已采纳
如果Luigi图中的某个任务需要在远程Hadoop集群上运行，这是否可行？运行Luigi的机器与Hadoop集群不同。luigi是否仍能检查远程集群中的HDFS文件是否存在？
浏览 13提问于2019-03-12得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号