process_queue: Rename Threaded_worker to ThreadedWorker.

Threaded_worker doesn't fit the python naming convention we rely on.
This commit is contained in:
Mateusz Mandera 2021-11-16 16:30:47 +01:00 committed by Alex Vandiver
parent 3688ff38bd
commit 2d3d0f862a
1 changed files with 2 additions and 2 deletions

View File

@ -75,7 +75,7 @@ class Command(BaseCommand):
if not settings.DEVELOPMENT:
logger.info("launching queue worker thread " + queue_name)
cnt += 1
td = Threaded_worker(queue_name, logger)
td = ThreadedWorker(queue_name, logger)
td.start()
assert len(queues) == cnt
logger.info("%d queue worker threads were launched", cnt)
@ -111,7 +111,7 @@ class Command(BaseCommand):
worker.start()
class Threaded_worker(threading.Thread):
class ThreadedWorker(threading.Thread):
def __init__(self, queue_name: str, logger: logging.Logger) -> None:
threading.Thread.__init__(self)
self.logger = logger