diff options
| -rwxr-xr-x | tools/merge_fetch.py | 4 |
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 |