diff --git a/sync_database.py b/sync_database.py index bc7d7c9b4fff57b65eb2610570fb8203c3546035..51c22c6d35ec1e52f40b79c3ca9bf7ec87d6b1b0 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()