Don't pass 0 to multiprocessing.Pipe.poll().

Documentation says to pass nothing for no blocking.

1 files changed, 2 insertions, 2 deletions

diff --git a/tools/merge_fetch.py b/tools/merge_fetch.py
index 801f9cf..e0a6243 100755
--- a/tools/merge_fetch.py
+++ b/tools/merge_fetch.py
@@ -119,7 +119,7 @@ def merge_fetch_worker(args, localconfig, storagenode, pipe):
     to_fetch = set()
     while True:
         ## Read all messages from parent.
-        while pipe.poll(0):
+        while pipe.poll():
             msg = pipe.recv()
             if len(msg) < 2:
                 continue
@@ -201,7 +201,7 @@ def merge_fetch_parallel(args, config, localconfig):
                                                storagenodes[name]])
                 continue
             logging.info("polling %s", name)
-            while pipe.poll(0):
+            while pipe.poll():
                 msg = pipe.recv()
                 if len(msg) < 2:
                     continue