Merge 123ca6e into 51972bb

frictionlessdata · May 28, 2019 · e00e7e1 · e00e7e1
2 parents 51972bb + 123ca6e
commit e00e7e1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/datapackage_pipelines/lib/load.py b/datapackage_pipelines/lib/load.py
@@ -20,8 +20,8 @@ def func(package):
     def mark_streaming(_from):
         def func(package):
             for i in range(num_resources, len(package.pkg.resources)):
-                package.pkg.descriptor['resources'][i][PROP_STREAMING] = True
-                package.pkg.descriptor['resources'][i][PROP_STREAMED_FROM] = _from
+                package.pkg.descriptor['resources'][i].setdefault(PROP_STREAMING, True)
+                package.pkg.descriptor['resources'][i].setdefault(PROP_STREAMED_FROM,  _from)
             yield package.pkg
             yield from package
         return func