diff --git a/inventory_provider/routes/jobs.py b/inventory_provider/routes/jobs.py index 1e04846bc28753f0786f538e18307b0891f37cd9..634e7bf248ca3c863cde05392f966392e21639ad 100644 --- a/inventory_provider/routes/jobs.py +++ b/inventory_provider/routes/jobs.py @@ -1,8 +1,14 @@ import json import logging +import queue +import random +import threading + from distutils.util import strtobool import jsonschema from flask import Blueprint, current_app, jsonify, Response, request + +from inventory_provider.tasks import common as tasks_common from inventory_provider.tasks import worker from inventory_provider.routes import common from inventory_provider.tasks.common import get_current_redis, get_latch @@ -83,10 +89,6 @@ LOG_ENTRY_SCHEMA = { "additionalProperties": True } -import queue -import random -import threading -from inventory_provider.tasks import common as tasks_common def _redis_client_proc(key_queue, value_queue, params): try: @@ -146,7 +148,7 @@ def load_task_log(): value = response_queue.get() if not value: num_finished += 1 - logger.debug(f'one worker thread finished') + logger.debug('one worker thread finished') continue info = tasks.setdefault(value['uuid'], {})