Added small timeout for local

Signed-off-by: Brandyn A. White <bwhite@dappervision.com>
wsxiaoys · Aug 23, 2012 · c230dcd · c230dcd
1 parent 212d885
commit c230dcd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/hadoopy/_local.py b/hadoopy/_local.py
@@ -97,7 +97,7 @@ def run_task(self, kvs, cmdenvs=(), poll=None):
                             elif w and not wrote:
                                 tbfp_w.write(kv)
                                 wrote = True
-                                timeout = 0
+                                timeout = .0001
                             if wrote and (poll is None or poll()):
                                 break
                 # Get any remaining values