我运行的是Windows7，Python 2.7 via Anaconda 4.3.17，Luigi 2.4.0，Pandas 0.18，sklearn版本0.18。根据下面的说明，我试图让一个luigi.LocalTarget输出成为一个pickle来存储几个不同的对象(使用firstJob)，然后在一个相关作业(secondJob)中从该pickle中读取。如果我从命令行运行以下命令，firstJob将成功完成：
"python -m luigi -- luigiPickl
浏览 0提问于2017-06-07得票数 6
回答已采纳
我正在尝试打开一个指向压缩文件的luigi.LocalTarget来读取(这样我就可以计算一个哈希值)。我可以做到这一点(没有luigi)，它工作得很好with open(file_path, 'rb') as f:但如果我这么做
target = luigi.LocalTarget(
浏览 2提问于2017-05-03得票数 0
我刚刚尝试运行文档中的python luigi ： def output(self): def requires(self): return
浏览 1提问于2015-07-17得票数 2
在我的项目中，在Luigi管道中编写二进制LocalTarget遇到了麻烦。我在这里隔离了这个问题： def output(self):我尝试以'w'和'wb'身份打开，但一直收到以下错误：
TypeError: write() argument must be
浏览 3提问于2016-08-27得票数 13
回答已采纳
1回答
如何通过测试修改类数据？
、、、、
我有这个luigi任务，它所需的输入是'test_file.txt‘。我想通过测试类来更改所需的输入。我需要更改输入，以便能够用文件测试类的功能。import pytest
def requires(self):return luigi.LocalTarget("test_file.txt")
浏览 7提问于2021-08-25得票数 1
回答已采纳
2回答
我试图构建一个从Luigi登录的策略，这样就有一个可配置的输出列表，包括stdout和一个自定义的文件列表。我希望能够在运行时设置日志记录级别。我们的系统用Luigi打电话给Jenkins的火花。
浏览 4提问于2016-06-16得票数 10
回答已采纳
1回答
我正在尝试使用docker和luigi https://hub.docker.com/r/spotify/luigi进行一些实验。 我用spotify/luigi创建了一个docker容器。我创建了一个共享卷，并将其映射到容器的/luigi/share/ import luigi def requires(
浏览 14提问于2019-10-05得票数 0
下面的代码片段适用于python2，但不适用于python3。此代码片段旨在允许luigi工作流写入多页PDF，同时仍使用允许原子性的LocalTarget上下文管理器。import luigiimport matplotlib.pyplot as plt
with te
浏览 23提问于2019-12-13得票数 1
我正在学习使用luigi，我想运行我编写的这个任务，它打开一个文件，修改它，然后重新保存输出： class WindDirection(luigi.Task): return luigi.LocalTarget("testing/wdir.nc"NCdata.wind_dir_from_component(uas_reade
浏览 1提问于2019-03-04得票数 1
回答已采纳
2回答
class BatchJobTask(luigi.Task) def run(self): return self.LocalTarger("downloaded_filelist.txt")
class BatchWorker(luigi.Task
浏览 7提问于2017-10-28得票数 1
回答已采纳
1回答
我正在尝试配置Luigi的重试机制，以便将失败的任务重试几次。但是，在成功重新尝试任务时，Luigi未成功退出：* 2 ran successfullyclass FailOnceThenSucceed(luigi.Task):
def output(self):return luigi.<
浏览 2提问于2016-10-24得票数 6
回答已采纳
class step1(luigi.Task):
with open('workfile1', 'w') as f: return [luigi.LocalTarget("workfile1class step2(<
浏览 3提问于2014-11-01得票数 0
1回答
问题是，在run类的CleanText方法中，我似乎无法在luigi.LocalTarget中使用unicode。任何想法都将不胜感激！a single LocalTarget root = os.path.dirname(os.path.abspath(inspect.getfile(inspect.currentframe()))) + "/"
浏览 2提问于2015-09-07得票数 1
回答已采纳
我正在使用luigi.build方法尝试luigi的多处理能力。但是我在执行的时候遇到了一些库错误。 custid= luigi.Parameter() def output(self):
return luigi.LocalTarget("logs
浏览 16提问于2017-08-11得票数 0
我有一个简单的luigi管道。import luigiimport row_count_test
open_file.write('{}'.format(output))
return luigi.LocalTarget() 我通过命令行运
浏览 17提问于2019-01-29得票数 0
4回答
就像一个新手一样，我想出了这个代码 return class2()def output(self): print 'IN classA'
de
浏览 12提问于2017-03-30得票数 16
回答已采纳
import randomimport luigi
return luigi.LocalTarget(".self.number), 'w') as f:
f.write(str(s
浏览 1提问于2017-06-05得票数 3
我最近开始使用Luigi，我想了解如何使用它不断地将新数据添加到现有的目标文件中。import luigi date = luigi.DateParameterdatetime.datetime.now())
return []
def output(self):
浏览 1提问于2017-03-22得票数 5
1回答
对Luigi问题的理解
、、、
看看ATask类 config = luigi.Parameter()
#Some Tasks maybe
return luigi.LocalTarget("A.txt")
config = luigi.Parameter()
def r
浏览 13提问于2022-02-14得票数 0
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号