fixed wrong queue class

This commit is contained in:
2021-05-21 20:54:48 +02:00
parent 374a419d62
commit 5868718602

View File

@@ -11,7 +11,7 @@ import signal
import subprocess import subprocess
import sys import sys
import time import time
from multiprocessing import Pool, Queue, current_process, Lock from multiprocessing import Pool, current_process, Lock, JoinableQueue
from queue import Empty from queue import Empty
import yaml import yaml
@@ -343,7 +343,7 @@ if __name__ == '__main__':
setup_chroot() setup_chroot()
sync_marchs_with_config() sync_marchs_with_config()
update_svn2git() update_svn2git()
q = Queue() q = JoinableQueue()
with Pool(config["build"]["worker"], initializer=run_worker) as pool: with Pool(config["build"]["worker"], initializer=run_worker) as pool:
fill_queue() fill_queue()