chore: add logs (#3247)

Author: MasterPtato

engine/packages/gasoline/src/ctx/workflow.rs

@@ -536,7 +536,7 @@ impl WorkflowCtx {
 
 	pub(crate) fn check_stop(&self) -> WorkflowResult<()> {
 		if self.stop.has_changed().unwrap_or(true) {
-			Err(WorkflowError::WorkflowStopped)
+			Err(WorkflowError::WorkflowEvicted)
 		} else {
 			Ok(())
 		}
@@ -546,7 +546,7 @@ impl WorkflowCtx {
 		// We have to clone here because this function can't have a mutable reference to self. The state of
 		// the stop channel doesn't matter because it only ever receives one message
 		let _ = self.stop.clone().changed().await;
-		Err(WorkflowError::WorkflowStopped)
+		Err(WorkflowError::WorkflowEvicted)
 	}
 }
 

engine/packages/gasoline/src/error.rs

@@ -28,8 +28,8 @@ pub enum WorkflowError {
 	#[error("workflow not found")]
 	WorkflowNotFound,
 
-	#[error("workflow stopped")]
-	WorkflowStopped,
+	#[error("workflow evicted")]
+	WorkflowEvicted,
 
 	#[error("history diverged: {0}")]
 	HistoryDiverged(String),
@@ -180,7 +180,7 @@ pub enum WorkflowError {
 
 impl WorkflowError {
 	pub(crate) fn wake_immediate(&self) -> bool {
-		matches!(self, WorkflowError::WorkflowStopped)
+		matches!(self, WorkflowError::WorkflowEvicted)
 	}
 
 	/// Returns the next deadline for a workflow to be woken up again based on the error.
@@ -225,7 +225,7 @@ impl WorkflowError {
 			| WorkflowError::NoSignalFoundAndSleep(_, _)
 			| WorkflowError::SubWorkflowIncomplete(_)
 			| WorkflowError::Sleep(_)
-			| WorkflowError::WorkflowStopped => true,
+			| WorkflowError::WorkflowEvicted => true,
 			_ => false,
 		}
 	}

engine/packages/pegboard-serverless/src/lib.rs

@@ -217,6 +217,8 @@ async fn tick_runner_config(
 	let drain_count = curr.len().saturating_sub(desired_count);
 	let start_count = desired_count.saturating_sub(curr.len());
 
+	tracing::debug!(%namespace_name, %runner_name, %desired_count, %drain_count, %start_count, "scaling");
+
 	if drain_count != 0 {
 		// TODO: Implement smart logic of draining runners with the lowest allocated actors
 		let draining_connections = curr.split_off(desired_count);
@@ -305,6 +307,8 @@ async fn outbound_handler(
 	shutdown_rx: oneshot::Receiver<()>,
 	draining: Arc<AtomicBool>,
 ) -> Result<()> {
+	tracing::debug!(%url, "sending outbound req");
+
 	let current_dc = ctx.config().topology().current_dc()?;
 
 	let client = rivet_pools::reqwest::client_no_timeout().await?;