Merge branch '24/schedule'

okfn · May 11, 2017 · fc207ba · fc207ba
2 parents 3e46c32 + 08b78b3
commit fc207ba
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/datapackage_pipelines_measure/generator.py b/datapackage_pipelines_measure/generator.py
@@ -5,7 +5,8 @@
 from datapackage_pipelines.generators import (
     GeneratorBase,
     steps,
-    slugify
+    slugify,
+    SCHEDULE_DAILY
 )
 
 from . import pipeline_steps
@@ -47,7 +48,7 @@ def get_schema(cls):
     @classmethod
     def generate_pipeline(cls, source):
         project_id = slugify(source['project'])
-        schedule = None
+        schedule = SCHEDULE_DAILY
 
         discovered_steps = cls._get_pipeline_steps()
 
@@ -77,6 +78,8 @@ def generate_pipeline(cls, source):
                 'pipeline': _steps
             }
             if schedule is not None:
-                pipeline_details['schedule']['crontab'] = schedule
+                pipeline_details['schedule'] = {
+                    'crontab': schedule
+                }
 
             yield pipeline_id, pipeline_details