We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 14c5aaa commit be4ab84Copy full SHA for be4ab84
opamp/opentelemetry-opamp-client/src/opentelemetry/_opamp/agent.py
@@ -249,15 +249,7 @@ def stop(self) -> None:
249
"Stopping OpAMPAgent: failed to send AgentDisconnect message"
250
)
251
252
- logger.debug("Stopping OpAMPAgent: cancelling jobs")
253
- # Clear pending jobs
254
- while True:
255
- try:
256
- self._queue.get_nowait()
257
- self._queue.task_done()
258
- except queue.Empty:
259
- break
260
-
+ logger.debug("Stopping OpAMPAgent: signaling threads")
261
# Signal threads to exit
262
self._stop.set()
263
# don't crash if the user calls stop() before start() or calls stop() multiple times
0 commit comments