Luigi:Rangehourly示例

Question

对于RangeHourly条款（或者类似的例子，比如RangeDaily）有什么可用的例子吗。我一直试图用它来重复执行任务。但我总是会遇到如下错误：

调试：检查RangeHourly（of=FinalTask，of_params={}，reverse=False，task_limit=50，now=None，param_name=None，start=2017-06-28215，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)