From 7e9f753c2fb738262e87a37d1db81750ea9db8ff Mon Sep 17 00:00:00 2001 From: Christian Date: Fri, 30 Aug 2019 17:05:57 +0100 Subject: [PATCH] No longer fires error on OSX --- sync_database.py | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/sync_database.py b/sync_database.py index bc7d7c9..51c22c6 100644 --- a/sync_database.py +++ b/sync_database.py @@ -86,10 +86,19 @@ def sync_database(): q = multiprocessing.Queue() pool = multiprocessing.Pool(len(eventlinks),process,(q,)) + try: + q.qsize() + ok = 0 + except NotImplementedError: + ok = 0 for i,link in enumerate(eventlinks): - while q.qsize() > 20: - time.sleep(1) - q.put([link,eventnames[i]]) + if ok == 1: + while q.qsize() > 20: + time.sleep(1) + q.put([link,eventnames[i]]) + elif ok == 0: + q.put([link,eventnames[i]]) + pool.close() pool.join() -- GitLab