diff --git a/datapackage_pipelines/lib/load.py b/datapackage_pipelines/lib/load.py
index 88755b97..597b35d5 100644
--- 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