herocode/herocoordinator
13
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Increase supervisor hub popmessage timeout

Browse Source 
Signed-off-by: Lee Smet <lee.smet@hotmail.com>
This commit is contained in:
Lee Smet
2025-09-08 11:43:44 +02:00
parent 66c89d2485
commit 8cea17f4ec
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/clients/supervisor_hub.rs
View File

@@ -48,7 +48,7 @@ impl SupervisorHub {
fn spawn_pop_loop(hub: Arc<Self>) { fn spawn_pop_loop(hub: Arc<Self>) {
tokio::spawn(async move { tokio::spawn(async move {
loop { loop {
match hub.mycelium.pop_message(Some(false), Some(2), None).await { match hub.mycelium.pop_message(Some(false), Some(20), None).await {
Ok(Some(inb)) => { Ok(Some(inb)) => {
// Extract and decode payload // Extract and decode payload
let Some(payload_b64) = inb.get("payload").and_then(|v| v.as_str()) else { let Some(payload_b64) = inb.get("payload").and_then(|v| v.as_str()) else {