@@ -222,7 +222,7 @@ async def _queue_worker(self) -> None:
222222 Selection policy: round-robin across queue keys. If a task is rate-limited
223223 at execution time, it is requeued and the worker tries other queues.
224224 """
225- print ('[TaskQueue] Worker started' )
225+ logger . debug ('[TaskQueue] Worker started' )
226226 while True :
227227 try :
228228 # Wait until there is at least one queue with a task
@@ -470,7 +470,7 @@ async def schedule_task(
470470 if self ._event_loop is None :
471471 self ._event_loop = asyncio .get_running_loop ()
472472
473- print (
473+ logger . debug (
474474 f'[TaskQueue] Scheduling task { request_id } , rps_limit={ self ._task_queue_config .rps_limit } , enabled={ self ._task_queue_config .enabled } ' # noqa: E501
475475 )
476476
@@ -487,7 +487,7 @@ async def schedule_task(
487487
488488 # 5. Put task in queue and update status
489489 q = self ._task_queues [queue_key ]
490- print (
490+ logger . debug (
491491 f'[TaskQueue] Adding task { request_id } to queue key={ queue_key } (current size: { q .qsize ()} ) type={ task_type } ' # noqa: E501
492492 )
493493 await q .put (
@@ -502,7 +502,7 @@ async def schedule_task(
502502 ))
503503 self .state .store_future_status (
504504 request_id , TaskStatus .QUEUED .value , model_id , queue_state = QueueState .ACTIVE .value )
505- print (f'[TaskQueue] Task { request_id } queued, new queue size: { q .qsize ()} key={ queue_key } ' )
505+ logger . debug (f'[TaskQueue] Task { request_id } queued, new queue size: { q .qsize ()} key={ queue_key } ' )
506506
507507 self ._new_task_event .set ()
508508
@@ -567,4 +567,4 @@ async def shutdown_task_queue(self) -> None:
567567 self ._task_queues .clear ()
568568 self ._queue_order .clear ()
569569
570- print ('[TaskQueue] Task queue shutdown complete' )
570+ logger . debug ('[TaskQueue] Task queue shutdown complete' )
0 commit comments