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 a9cb58e commit aacdcfdCopy full SHA for aacdcfd
src/sentry/buffer/redis.py
@@ -312,15 +312,10 @@ def get_hash(
312
return decoded_hash
313
314
def process_batch(self) -> None:
315
- client = get_cluster_routing_client(self.cluster, self.is_redis_cluster)
316
- lock_key = self._lock_key(client, self.pending_key, ex=10)
317
- if not lock_key:
318
- return
319
-
320
try:
321
redis_buffer_registry.callback(BufferHookEvent.FLUSH, self)
322
- finally:
323
- client.delete(lock_key)
+ except Exception:
+ logger.exception("process_batch.error")
324
325
def incr(
326
self,
0 commit comments