Function _try_acquire_lock

apps/output/streaming_chunk_cache.py:86–87 · view source on GitHub ↗

(redis, base_key, lock_ttl)

Source from the content-addressed store, hash-verified

84
85
86	def _try_acquire_lock(redis, base_key, lock_ttl):
87	return bool(redis.set(_lock_key(base_key), "1", nx=True, ex=lock_ttl))
88
89
90	def _refresh_build_ttl(redis, base_key, lock_ttl):

_stream_followFunction · 0.85

stream_cached_responseFunction · 0.85

_lock_keyFunction · 0.85

setMethod · 0.45

no test coverage detected