Firehose and PrimeState: put_nonblocking

This commit is contained in:
Shane Smiskol
2026-05-09 01:27:47 -07:00
parent 5745909e9b
commit a3d3d0fea6
2 changed files with 2 additions and 2 deletions
+1 -1
View File
@@ -65,7 +65,7 @@ class PrimeState:
with self._lock:
if prime_type != self.prime_type:
self.prime_type = prime_type
self._params.put("PrimeType", int(prime_type))
self._params.put_nonblocking("PrimeType", int(prime_type))
cloudlog.info(f"Prime type updated to {prime_type}")
def _worker_thread(self) -> None:
@@ -207,7 +207,7 @@ class FirehoseLayoutBase(Widget):
if response.status_code == 200:
data = response.json()
self._segment_count = data.get("firehose", 0)
self._params.put(self.PARAM_KEY, data)
self._params.put_nonblocking(self.PARAM_KEY, data)
except Exception as e:
cloudlog.error(f"Failed to fetch firehose stats: {e}")