(redis, base_key, lock_ttl)
| 88 | |
| 89 | |
| 90 | def _refresh_build_ttl(redis, base_key, lock_ttl): |
| 91 | redis.expire(_lock_key(base_key), lock_ttl) |
| 92 | redis.expire(_status_key(base_key), lock_ttl) |
| 93 | redis.expire(_chunks_key(base_key), lock_ttl) |
| 94 | |
| 95 | |
| 96 | def _stream_ready(redis, base_key): |
no test coverage detected