work without valid local conf checked
parent
ebff93698c
commit
0b61f56bca
|
|
@ -31,4 +31,3 @@
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -336,7 +336,6 @@ pub async fn subscribe_config_stream(actual_prcs: Arc<Processes>, params: Arc<Pr
|
||||||
info!("Runner subscribed on config update publishing in channel {}", &channel_name);
|
info!("Runner subscribed on config update publishing in channel {}", &channel_name);
|
||||||
loop {
|
loop {
|
||||||
if let Ok(msg) = pubsub.get_message() {
|
if let Ok(msg) = pubsub.get_message() {
|
||||||
info!("New config was pulled from Redis Server");
|
|
||||||
let get_remote_config: Result<String, redis::RedisError> = msg.get_payload();
|
let get_remote_config: Result<String, redis::RedisError> = msg.get_payload();
|
||||||
match get_remote_config {
|
match get_remote_config {
|
||||||
Ok(payload) => {
|
Ok(payload) => {
|
||||||
|
|
@ -353,7 +352,10 @@ pub async fn subscribe_config_stream(actual_prcs: Arc<Processes>, params: Arc<Pr
|
||||||
return Err(CustomError::Fatal);
|
return Err(CustomError::Fatal);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
_ => continue,
|
_ => {
|
||||||
|
warn!("Pulled new config. Current config is more actual ...");
|
||||||
|
continue
|
||||||
|
},
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue