sitemaps

Author: akariv

datapackage_pipelines_migdar/flows/publications.py

@@ -60,6 +60,7 @@ def one(i):
 def get_sheets():
     def func(rows):
         for row in rows:
+            print('Attempting with %r' % row)
             wb = load_workbook(row['filename'])
             for sheet_name in wb.sheetnames:
                 if 'deleted' in sheet_name.strip().lower():

datapackage_pipelines_migdar/flows/sitemap.py

@@ -35,7 +35,7 @@ def flow(*_):
             ]
         ],
         DF.concatenate(dict(doc_id=[])),
-        DF.update_resource(**{'dpp:streaming': True}),
+        DF.update_resource(-1, **{'dpp:streaming': True}),
         registerSiteMaps,
         DF.printer()
     )