- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在为 Luigi 中一个我不理解的错误而苦苦挣扎。我不知道这是一个已知问题、Luigi 的限制还是我做错了什么。
我在一个有很多任务和很多依赖的真实问题中使用 Luigi。但是,我做了一个玩具示例,其中清楚地显示了这个问题。
让我们考虑两个任务,TaskA 和 TaskB,TaskA 需要执行具有不同 Luigi 参数值的 TaskB 的两个先前实例。
如果我在 TaksA 的 requires() 方法中编写依赖项,则不会发生任何不良情况。所有三个任务都执行,并且我写入了退出文件。
但是如果我在 TaksA 的 run() 方法中编写依赖项,那么我会得到丑陋的 TaskClassAmbigiousException。
在我的实际问题中,我无法在 requires() 方法中产生任务,因为我需要知道在 requieres() 方法中也产生的先前任务的结果,所以我尝试在中产生任务run() 并得到相同的异常。
好的,这是玩具示例的代码。首先,在 requieres() 中生成任务,它起作用了:
import luigi
class TaskB(luigi.Task):
j = luigi.IntParameter(default=1)
def output(self):
return luigi.LocalTarget("data/outputB{j}.txt".format(j=self.j))
def requires(self):
pass
def run(self):
print_file = 'TaskB' + str(self.j)
with self.output().open('w') as out_file:
out_file.write(print_file)
class TaskA(luigi.Task):
i = luigi.IntParameter(default=1)
def output(self):
return luigi.LocalTarget("data/outputA{i}.txt".format(i=self.i))
def requires(self):
yield TaskB(j=self.i)
yield TaskB(j=self.i+1)
def run(self):
print_file = ""
for input_target in self.input():
with input_target.open('r') as in_file:
for line in in_file:
print_file+=line + 'TaskA' + str(self.i)
with self.output().open('w') as out_file:
out_file.write(print_file)
if __name__ == '__main__':
taskA = TaskA(i=2)
其次,在 run() 中产生任务,我得到了这个:
File "/home/ppo0011l/.conda/envs/nudge/lib/python3.6/site-packages/luigi/worker.py", line 1081, in _handle_next_task
for module, name, params in new_requirements]
File "/home/ppo0011l/.conda/envs/nudge/lib/python3.6/site-packages/luigi/worker.py", line 1081, in <listcomp>
for module, name, params in new_requirements]
File "/home/ppo0011l/.conda/envs/nudge/lib/python3.6/site-packages/luigi/task_register.py", line 251, in load_task
task_cls = Register.get_task_cls(task_name)
File "/home/ppo0011l/.conda/envs/nudge/lib/python3.6/site-packages/luigi/task_register.py", line 181, in get_task_cls
raise TaskClassAmbigiousException('Task %r is ambiguous' % name)
代码:
import luigi
class TaskB(luigi.Task):
j = luigi.IntParameter(default=1)
def output(self):
return luigi.LocalTarget("data/outputB{j}.txt".format(j=self.j))
def requires(self):
pass
def run(self):
print_file = 'TaskB' + str(self.j)
with self.output().open('w') as out_file:
out_file.write(print_file)
class TaskA(luigi.Task):
i = luigi.IntParameter(default=1)
def output(self):
return luigi.LocalTarget("data/outputA{i}.txt".format(i=self.i))
def requires(self):
pass
def run(self):
print_file = ""
target1 = yield TaskB(j=self.i)
target2 = yield TaskB(j=self.i+1)
for input_target in [target1, target2]:
with input_target.open('r') as in_file:
for line in in_file:
print_file+=line + 'TaskA' + str(self.i)
with self.output().open('w') as out_file:
out_file.write(print_file)
if __name__ == '__main__':
taskA = TaskA(i=2)
luigi.build([taskA], workers=1,local_scheduler=True,log_level='WARNING')
编辑:我编辑以添加另一个相关问题。因为我想做的是产生一个任务,其参数取决于先前产生的任务,如果这对我来说可能就足够了:
def requires(self):
taskb_target = yield TaskB(j=self.i)
taskb_target.open('r')
# do something and yield next Task depending on what taskb_target has
yield TaskB(j=self.i+1)
但不幸的是,这不起作用。 Luigi 说“NoneType”对象没有属性“open”。
但是,当您在 run() 方法中生成任务时,您可以在运行时访问输出。好像有很大的不对称...
第二次编辑:
我做了更多的试验,我发现了一个奇怪的结论:我在原始问题中编写的第二段代码(当在 .py 文件中时)可以永远执行,即使删除输出文件和所以迫使 luigi 重新执行任务。但是,第一段代码只能执行一次(然后,在第一次执行时,它就起作用了!!)。但是如果删除文件再执行代码,就会出现ambiguous task错误。
我觉得跟luigi的Register对象有关系。但真正让我感到困惑的是,无论我是在 requieres 中还是在 run 方法中产生 taskB,这种行为都是不同的。
我仍然不知道问题是否出现在重新定义已经在 luigi 的 Register 模块中的类 Tasks 时。可能是...我还尝试将类定义放在与主 .py 不同的 .py 中,但是运行两次时它会中断。正常运行的唯一方法是重新启动内核,你只有一次机会!
最佳答案
当您使用 yield
时,您不会获得返回值,因为您基本上是从协程中返回
一个值。我真的很惊讶在 requires
中使用 yield
对你有用,因为它让我崩溃了。您要做的是先定义然后 yield 任务。因此,例如,您将拥有:
class TaskA(luigi.Task):
def run(self):
task_1 = TaskB(j=self.i)
yield task_1
with task_1.output().open('r') as in_file:
# Get data
task_2 = TaskB(j=self.i+1, ...)
yield task_2
...
关于python - 在 run() 中产生任务时 Luigi 中的 TaskClassAmbigiousException,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/65803757/
我已经通过 AVD 管理器启动了我的模拟器,一旦它运行,我点击了 run app。我已经等了几分钟,我的正在运行的设备出现在 选择一个正在运行的设备 中,但窗口始终保持空白。 最佳答案 您正在运行的项
我想在安装新数据库之前删除旧数据库,以便为用户更新它。 我有以下情况: 在我的 Components 部分中,我为用户提供了一个选项: [Components] Name: "updateDataba
如果我将一个 Python 模块实现为一个目录(即包),它同时具有顶级函数 run 和子模块 run,我可以指望 from example import run 总是导入函数?根据我的测试,至少在 L
我在 Eclipse Juno 上使用 Tomcat 7。我使用工作区元数据作为服务器位置(请参阅下面的我的 tomcat 配置)。 我也收到了 服务器项目在 eclipse [请看下图] 中使用单独
我正在做一些测试以了解 java 中的不同线程状态,并且遇到了一些查询。 通常,当一个线程被实例化时,它被称为处于 "NEW" 状态,然后当调用它的 start() 方法时,操作系统调度程序获得控制权
当我使用命令 npm run build -- --prod 时,我收到以下错误消息: 属性“PropertyName1”是私有(private)属性,只能在“AppComponent”类中访问 “A
我正在尝试将默认的“运行”键盘快捷键更改为 ⌘R。 - 因为我不想每次都伸手去拿触控板,而且我的手指不够长,无法一次执行⌥⇧F10。 “运行”和“运行...”有什么区别? 最佳答案 ... 用于菜单中
我现在不知道如何编写一个合适的方法来测试这种行为。请不要投反对票.. 我现在有一个 java 类负责处理数据并将数据添加到多个数据库。每个数据库都保存相同的数据,但处理方式不同(例如,以不同的插值率进
我知道不应该调用 run 方法来启动新线程执行,但我指的是 this article他们在另一个 run 方法中调用了 runnable.run(); ,这似乎暗示它启动了一个新线程或者根本没有cre
当我尝试在Windows 10/11下使用Eclipse 2023-06调试任何应用程序(甚至是hello.c)时,我总是收到以下错误:。该错误清楚地指示-(错误2)-路径是错误的。。我试图在互联网上
在运行vue文件时,需要进行npm操作,但我们发现,有时候用的是npm run serve,而有的时候用的是npm run dev,二者有什么区别 在我们运行一些 vue 项目的时候,输入npm ru
我想在 cloud run 上运行一个长时间运行的作业。该任务可能执行超过 30 分钟,并且主要发送 API 请求。cloud run 在大约 20 分钟后停止执行,从指标来看,它似乎没有识别出我的任
我们无法让 SSE 从 Google Cloud Run 上的容器发送。我已经尝试使用一个简单的 SSE 示例( https://github.com/kljensen/node-sse-exampl
直到最近,我一直在执行这个美丽来构建 + 运行一个带有堆栈的项目: stack build && .stack-work/install/x86_64-linux/lts-4.1/7.10.3/bin
我们有一个小脚本,可以抓取网页(约 17 个条目),并将它们写入 Firestore 集合。为此,我们在 Google Cloud Run 上部署了一项服务。 这段代码的执行需要大约 5 秒 when
我是Docker的新手,我知道一种运行交互式容器的方法如下: $ docker run -it image-name bash 要么 $ docker run -it image-name /bin/
Dockerfile 中的多个 RUN 条目之间有什么区别,例如: FROM php:5.6-apache RUN docker-php-ext-install mysqli RUN apt upda
对于来自文档的云运行内存使用情况 ( https://cloud.google.com/run/docs/configuring/memory-limits ) Cloud Run applicati
今天早上我更新了我的 Ubuntu 版本,现在我无法从 eclipse 运行我的应用程序。 问题是,当我单击“运行方式”时出现的列表是空的,我无法运行任何内容。 我该如何解决这个问题? 我能看到的唯一
我正在 intelliJ 上使用 livereload 测试 spring-boot-devtools。我有一个简单的 SpringBootApplication,可以正常工作。 当我从 maven
我是一名优秀的程序员,十分优秀!