Fix for python output not working with key, value

patcoll · May 21, 2012 · b26e1fb · b26e1fb
1 parent 35be305
commit b26e1fb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/streaming/language_support/python/pymongo_hadoop/output.py b/streaming/language_support/python/pymongo_hadoop/output.py
@@ -32,7 +32,7 @@ def _write(self, obj):
     def _writes(self, iterable):
         w = self.write
         for obj in iterable:
-            if isinstance(obj, dict):
+            if isinstance(obj, dict) or (isinstance(obj, tuple) and len(obj) == 2):
                 w(obj)
             elif isinstance(obj, collections.Iterable):
                 for o in obj: