From 76ed6d966051c56f8e894c18461c5ea284b1a74b Mon Sep 17 00:00:00 2001
From: Yury Akudovich <ya@matterlabs.dev>
Date: Thu, 17 Oct 2024 12:15:41 +0200
Subject: [PATCH] fix(prover): Do not exit on missing watcher data. (#3119)
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

## What ❔

Do not exit on missing watcher data.
<!-- What are the changes this PR brings about? -->
<!-- Example: This PR adds a PR template to the repo. -->
<!-- (For bigger PRs adding more context is appreciated) -->

## Why ❔

To fix always exiting in `scaler_period` after start due to missing
data.

<!-- Why are these changes done? What goal do they contribute to? What
are the principles behind them? -->
<!-- Example: PR templates ensure PR reviewers, observers, and future
iterators are in context about the evolution of repos. -->

## Checklist

<!-- Check your PR fulfills the following items. -->
<!-- For draft PRs check the boxes as you complete them. -->

- [x] PR title corresponds to the body of PR (we generate changelog
entries from PRs).
- [ ] Tests for the changes have been added / updated.
- [ ] Documentation comments have been added / updated.
- [x] Code has been formatted via `zkstack dev fmt` and `zkstack dev
lint`.

ref ZKD-1855
---
 prover/crates/bin/prover_autoscaler/src/global/scaler.rs | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/prover/crates/bin/prover_autoscaler/src/global/scaler.rs b/prover/crates/bin/prover_autoscaler/src/global/scaler.rs
index 75c9e2e3e422..dd3f3cf1ad3a 100644
--- a/prover/crates/bin/prover_autoscaler/src/global/scaler.rs
+++ b/prover/crates/bin/prover_autoscaler/src/global/scaler.rs
@@ -305,7 +305,10 @@ impl Task for Scaler {
         let queue = self.queuer.get_queue().await.unwrap();
 
         let guard = self.watcher.data.lock().await;
-        watcher::check_is_ready(&guard.is_ready)?;
+        if let Err(err) = watcher::check_is_ready(&guard.is_ready) {
+            tracing::warn!("Skipping Scaler run: {}", err);
+            return Ok(());
+        }
 
         for (ns, ppv) in &self.namespaces {
             let q = queue.queue.get(ppv).cloned().unwrap_or(0);