diff --git a/preprocessor/preprocessor/daemon.py b/preprocessor/preprocessor/daemon.py index da6387dcccfe4f656717e1bacad0ebf6601c40a1..e44a3c9079f341b59fcf3384be2bd97d7f811ca1 100644 --- a/preprocessor/preprocessor/daemon.py +++ b/preprocessor/preprocessor/daemon.py @@ -20,7 +20,7 @@ def run_daemon(config, host, port, listen_queue, listen_md_queue, write_queue): logger.debug("waiting for redis queue '%s'..." % listen_queue) while True: # fetch an item from the queue to be preprocessed - value, queue = client.brpop([listen_queue, listen_md_queue]) + queue, value = client.brpop([listen_queue, listen_md_queue]) file_paths = [] # start the preprocessing on that file if queue == listen_queue: