Merge branch 'master' of https://github.com/wamdam/riak-python-client into pevm-wamdam-strfun

Author: evanmcc

riak/mapreduce.py

@@ -546,6 +546,9 @@ def to_array(self):
             stepdef['module'] = self._function[0]
             stepdef['function'] = self._function[1]
 
+        elif (self._language == 'erlang' and isinstance(self._function, str)):
+            stepdef['source'] = self._function
+
         return {self._type: stepdef}