4

我有通过触发 Luigi

luigi.run(["--local-scheduler"], main_task_cls=Test(Server = ActiveServer, Database = DB))   

在我的课堂上,我有:

class Test(luigi.Task):

    Database = luigi.Parameter()
    Server = luigi.Parameter()

但是任务测试似乎无法解析我正确输入的参数?

我正进入(状态:

MissingParameterException: No value for 'Server' (--Server) submitted and no default value has been assigned.
4

1 回答 1

7

据我所知,您不能通过参数发送main_task_cls参数,只能通过类本身。可以改为通过参数发送cmdline_args参数,如下所示:

luigi.run(
    cmdline_args=["--local-scheduler",
                  "--server=ActiveServer",
                  "--database=DB"], 
    main_task_cls=Test)

另请注意,您可以使用local_scheduler关键字参数而不是通过参数发送,因此您得到:luigi.run()--local-schedulercmdline_args

luigi.run(
    cmdline_args=["--Server=ActiveServer",
                  "--Database=DB"], 
    main_task_cls=Test
    local_scheduler=True)
于 2015-09-01T16:32:32.077 回答