Permalink
Browse files

An error message changed slightly

  • Loading branch information...
1 parent 898ad13 commit ac1bc6314bfe71ea6028ba3f03ff33d767344fad Gabor Szabo committed Apr 30, 2012
Showing with 3 additions and 2 deletions.
  1. +3 −2 python/pycascading/pipe.py
@@ -308,8 +308,9 @@ def _create_with_parent(self, parent):
isinstance(parent.get_assembly(), cascading.pipe.GroupBy):
my_type = 'buffer'
else:
- raise Exception('Function was not decorated, and I cannot ' \
- 'decide if it is a map or a filter')
+ raise Exception('Function was not decorated with @udf_map or' \
+ ' @udf_filter, and I cannot decide if it is' \
+ ' a map or a filter')
if my_type == 'map':
import each
return each.Apply(self)._create_with_parent(parent)

0 comments on commit ac1bc63

Please sign in to comment.