python - 路易吉 : Rangehourly Examples

Question

是否有任何适用于 RangeHourly 条款的示例(或类似的示例，例如 RangeDaily)。我一直在尝试使用它来重复执行任务。但我总是会收到如下错误:

DEBUG:检查 RangeHourly(of=FinalTask​​, of_params={},verse=False,task_limit=50,now=None,param_name=None,start=2017-06-28T15,stop=None,hours_back =0, hours_forward=0) 完成调试:空范围。预计没有 FinalTask​​ 实例

下面是任务的定义:

class FinalTask (luigi.Task):
    start = luigi.DateHourParameter()
    def requires(self):
            return CleanupTask()
    def run(self):
            cmd='echo "Workflow Completed"'
            args=shlex.split(cmd)
            exc=subprocess.Popen(args,stdout=subprocess.PIPE,stderr=subprocess.PIPE)
            stdout,stderr=exc.communicate()
            self.output().open('w').close()
    def output(self):
            return luigi.LocalTarget('/var/flags/FinalTask_success_%s.csv' %start)

是否有我遗漏的东西导致了这个问题？

Answer 1

python tasks.py RangeHourlyBase --of FinalTask --start 2017-07-31T00 --stop 2017-07-31T23 --local-scheduler --workers 4

请注意:

• 您必须将 tasks.py 替换为定义 FinalTask​​ 的文件名。
• --local-scheduler 仅用于在本地运行任务。不要在生产环境中使用它。

• 最后一行有错误:start未定义，应该是:

  return luigi.LocalTarget('/var/flags/FinalTask_success_%s.csv' % self.start)