v0.0.44 event better error logs for join

datahq · Mar 9, 2019 · 120bb50 · 120bb50
1 parent 3513553
commit 120bb50
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/dataflows/VERSION b/dataflows/VERSION
@@ -1 +1 @@
-0.0.43
+0.0.44
diff --git a/dataflows/processors/join.py b/dataflows/processors/join.py
@@ -272,11 +272,11 @@ def process_datapackage(datapackage):
 
         resource_names = [resource['name'] for resource in datapackage['resources']]
         assert source_name in resource_names, \
-            'Source resource ({}) not found package (target={})'\
-            .format(source_name, target_name)
+            'Source resource ({}) not found package (target={}, found: {})'\
+            .format(source_name, target_name, resource_names)
         assert target_name in resource_names, \
-            'Target resource ({}) not found package (source={})'\
-            .format(target_name, source_name)
+            'Target resource ({}) not found package (source={}, found: {})'\
+            .format(target_name, source_name, resource_names)
 
         for resource in datapackage['resources']:
 
@@ -295,8 +295,8 @@ def process_datapackage(datapackage):
 
             elif resource['name'] == target_name:
                 assert isinstance(source_spec, dict),\
-                       'Source resource ({}) must appear before target resource ({})'\
-                       .format(source_name, target_name)
+                       'Source resource ({}) must appear before target resource ({}), found: {}'\
+                       .format(source_name, target_name, resource_names)
                 resource = process_target_resource(source_spec, resource)
                 new_resources.append(resource)