From ec15b264832307c2e8c2e471d3cc3f661170f0d8 Mon Sep 17 00:00:00 2001 From: Daniel Sanche Date: Mon, 6 Jan 2025 15:49:37 -0800 Subject: [PATCH] clear watch resources on cleanup --- google/cloud/firestore_v1/watch.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/google/cloud/firestore_v1/watch.py b/google/cloud/firestore_v1/watch.py index 63bb522b92..62b53ef4a9 100644 --- a/google/cloud/firestore_v1/watch.py +++ b/google/cloud/firestore_v1/watch.py @@ -333,9 +333,13 @@ def close(self, reason=None): if self.is_active: _LOGGER.debug("Stopping consumer.") self._consumer.stop() + self._consumer._on_response = None self._consumer = None + self._snapshot_callback = None self._rpc.close() + self._rpc._initial_request = None + self._rpc._callbacks = [] self._rpc = None self._closed = True _LOGGER.debug("Finished stopping manager.")