mirrors/magic-nix-cache
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

cleanup

Browse source
This commit is contained in:
Graham Christensen 2024-06-12 15:46:52 -04:00
parent 9c7b8e3fc9
commit 4dd3242a14
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
gha-cache/src/api.rs
View file

@ -334,7 +334,7 @@ impl Api {
where where
S: AsyncRead + Unpin + Send, S: AsyncRead + Unpin + Send,
{ {
if self.circuit_breaker_429_tripped.load(Ordering::Relaxed) { if self.circuit_breaker_tripped() {
return Err(Error::CircuitBreakerTripped); return Err(Error::CircuitBreakerTripped);
} }
@ -422,7 +422,7 @@ impl Api {
/// Downloads a file based on a list of key prefixes. /// Downloads a file based on a list of key prefixes.
pub async fn get_file_url(&self, keys: &[&str]) -> Result<Option<String>> { pub async fn get_file_url(&self, keys: &[&str]) -> Result<Option<String>> {
if self.circuit_breaker_429_tripped.load(Ordering::Relaxed) { if self.circuit_breaker_tripped() {
return Err(Error::CircuitBreakerTripped); return Err(Error::CircuitBreakerTripped);
} }
@ -444,7 +444,7 @@ impl Api {
/// Retrieves a cache based on a list of key prefixes. /// Retrieves a cache based on a list of key prefixes.
async fn get_cache_entry(&self, keys: &[&str]) -> Result<Option<ArtifactCacheEntry>> { async fn get_cache_entry(&self, keys: &[&str]) -> Result<Option<ArtifactCacheEntry>> {
if self.circuit_breaker_429_tripped.load(Ordering::Relaxed) { if self.circuit_breaker_tripped() {
return Err(Error::CircuitBreakerTripped); return Err(Error::CircuitBreakerTripped);
} }
@ -478,7 +478,7 @@ impl Api {
cache_size: Option<usize>, cache_size: Option<usize>,
) -> Result<ReserveCacheResponse> { ) -> Result<ReserveCacheResponse> {
if self.circuit_breaker_429_tripped.load(Ordering::Relaxed) { if self.circuit_breaker_tripped() {
return Err(Error::CircuitBreakerTripped); return Err(Error::CircuitBreakerTripped);
} }
@ -508,7 +508,7 @@ impl Api {
/// Finalizes uploading to a cache. /// Finalizes uploading to a cache.
async fn commit_cache(&self, cache_id: CacheId, size: usize) -> Result<()> { async fn commit_cache(&self, cache_id: CacheId, size: usize) -> Result<()> {
if self.circuit_breaker_429_tripped.load(Ordering::Relaxed) { if self.circuit_breaker_tripped() {
return Err(Error::CircuitBreakerTripped); return Err(Error::CircuitBreakerTripped);
} }