diff --git a/src/taskworker.py b/src/taskworker.py index c58f9a69..0eeb114d 100644 --- a/src/taskworker.py +++ b/src/taskworker.py @@ -10,7 +10,7 @@ def main(job_request): - request_id, job_id, process_id, thread_id = job_request.split(',') + request_id, job_id, process_id, thread_id = job_request.split(",") logger.info( "Starting Kolibri task worker, for job {} and request {}".format( job_id, request_id @@ -21,9 +21,9 @@ def main(job_request): from kolibri.core.tasks.worker import execute_job # noqa: E402 execute_job( - job_id, - worker_process=str(process_id), - worker_thread=str(thread_id), + job_id, + worker_process=str(process_id), + worker_thread=str(thread_id), worker_extra=str(request_id), )