File tree Expand file tree Collapse file tree 2 files changed +0
-7
lines changed
Expand file tree Collapse file tree 2 files changed +0
-7
lines changed Original file line number Diff line number Diff line change @@ -36,11 +36,6 @@ def __init__(self) -> None:
3636 ] = {}
3737 self ._unsubscribe_stick_events : Callable [[], None ] | None = None
3838
39- @property
40- def queue_depth (self ) -> int :
41- """Return estimated size of pending responses."""
42- return self ._sender .processed_messages - self ._receiver .processed_messages
43-
4439 def correct_received_messages (self , correction : int ) -> None :
4540 """Correct received messages count."""
4641 self ._receiver .correct_processed_messages (correction )
Original file line number Diff line number Diff line change @@ -196,12 +196,10 @@ async def _send_queue_worker(self) -> None:
196196 self ._submit_queue .task_done ()
197197 return
198198
199- queue_depth = self ._stick .queue_depth - self ._submit_queue .dropped_msgs
200199 if self ._submit_queue .qsize () > 3 :
201200 _LOGGER .warning (
202201 "Awaiting responses (qsize) %d" , self ._submit_queue .qsize ()
203202 )
204- _LOGGER .warning ("Awaiting responses (queu_depth) %d" , queue_depth )
205203 _LOGGER .warning ("Queue contents: %s" , self ._submit_queue ._queue )
206204 _LOGGER .warning ("Requests dropped: %d" , self ._submit_queue .dropped_msgs )
207205 await sleep (0.125 )
You can’t perform that action at this time.
0 commit comments