Using the HEARTBEAT as the delete pipeline observation period.

Author: fulmicoton

quickwit/quickwit-actors/src/actor.rs

@@ -408,9 +408,7 @@ impl<A: Actor> ActorContext<A> {
 
     pub(crate) fn observe(&self, actor: &mut A) -> A::ObservableState {
         let obs_state = actor.observable_state();
-        let _ = self
-            .observable_state_tx
-            .send(obs_state.clone());
+        let _ = self.observable_state_tx.send(obs_state.clone());
         obs_state
     }
 

quickwit/quickwit-common/src/net.rs

@@ -210,7 +210,6 @@ impl Display for HostAddr {
 /// Finds a random available TCP port.
 ///
 /// This function induces a race condition, use it only in unit tests.
-#[cfg(any(test, feature = "testsuite"))]
 pub fn find_available_tcp_port() -> anyhow::Result<u16> {
     let socket: SocketAddr = ([127, 0, 0, 1], 0u16).into();
     let listener = TcpListener::bind(socket)?;

quickwit/quickwit-janitor/src/actors/delete_task_pipeline.rs

@@ -19,11 +19,11 @@
 
 use std::path::PathBuf;
 use std::sync::Arc;
-use std::time::Duration;
 
 use async_trait::async_trait;
 use quickwit_actors::{
     Actor, ActorContext, ActorExitStatus, ActorHandle, Handler, Supervisor, SupervisorState,
+    HEARTBEAT,
 };
 use quickwit_common::io::IoControls;
 use quickwit_common::KillSwitch;
@@ -265,7 +265,7 @@ impl Handler<Observe> for DeleteTaskPipeline {
             }
         }
         // Supervisors supervise every `HEARTBEAT`. We can wait a bit more to observe supervisors.
-        ctx.schedule_self_msg(Duration::from_secs(5), Observe).await;
+        ctx.schedule_self_msg(HEARTBEAT, Observe).await;
         Ok(())
     }
 }