chore: change log levels

Author: MasterPtato

engine/packages/api-public/src/runner_configs/upsert.rs

@@ -171,7 +171,7 @@ async fn upsert_inner(
 			)
 			.await
 			{
-				tracing::warn!(?err, runner_name = ?path.runner_name, "failed to refresh runner config metadata");
+				tracing::warn!(?err, runner_name=?path.runner_name, "failed to refresh runner config metadata");
 			}
 		} else {
 			tracing::debug!("endpoint config unchanged, skipping metadata refresh");

engine/packages/cache-purge/src/lib.rs

@@ -5,13 +5,11 @@ use universalpubsub::NextOutput;
 
 #[tracing::instrument(skip_all)]
 pub async fn start(config: rivet_config::Config, pools: rivet_pools::Pools) -> Result<()> {
-	tracing::info!("starting cache purge subscriber service");
-
 	// Subscribe to cache purge updates
 	let ups = pools.ups()?;
 	let mut sub = ups.subscribe(CACHE_PURGE_TOPIC).await?;
 
-	tracing::info!(subject = ?CACHE_PURGE_TOPIC, "subscribed to cache purge updates");
+	tracing::info!(subject=?CACHE_PURGE_TOPIC, "subscribed to cache purge updates");
 
 	// Get cache instance
 	let cache = rivet_cache::CacheInner::from_env(&config, pools)?;
@@ -42,7 +40,5 @@ pub async fn start(config: rivet_config::Config, pools: rivet_pools::Pools) -> R
 		}
 	}
 
-	tracing::warn!("cache purge subscriber service stopped");
-
 	Ok(())
 }

engine/packages/engine/src/main.rs

@@ -25,7 +25,7 @@ async fn main_inner() -> Result<()> {
 
 	// Load config
 	let config = rivet_config::Config::load(&cli.config).await?;
-	tracing::info!(config = ?*config, "loaded config");
+	tracing::info!(config=?*config, "loaded config");
 
 	// Initialize telemetry (does nothing if telemetry is disabled)
 	let _guard = rivet_telemetry::init(&config);

engine/packages/epoxy/src/http_client.rs

@@ -57,7 +57,7 @@ where
 	)
 	.collect::<FuturesUnordered<_>>()
 	.await;
-	tracing::info!(?quorum_size, len = ?responses.len(), ?quorum_type, "fanout quorum size");
+	tracing::debug!(?quorum_size, len = ?responses.len(), ?quorum_type, "fanout quorum size");
 
 	// Choose how many successful responses we need before considering a success
 	let target_responses = match quorum_type {
@@ -115,7 +115,7 @@ pub async fn send_message_to_address(
 	let to_replica_id = request.to_replica_id;
 
 	if from_replica_id == to_replica_id {
-		tracing::info!(
+		tracing::debug!(
 			to_replica = to_replica_id,
 			"sending message to replica directly"
 		);
@@ -126,7 +126,7 @@ pub async fn send_message_to_address(
 	let mut replica_url = url::Url::parse(&replica_url)?;
 	replica_url.set_path(&format!("/v{PROTOCOL_VERSION}/epoxy/message"));
 
-	tracing::info!(
+	tracing::debug!(
 		to_replica = to_replica_id,
 		%replica_url,
 		"sending message to replica via http"
@@ -183,7 +183,7 @@ pub async fn send_message_to_address(
 	let body = response.bytes().await?;
 	let response_body = versioned::Response::deserialize(&body)?;
 
-	tracing::info!(
+	tracing::debug!(
 		to_replica = to_replica_id,
 		"successfully sent message via http"
 	);

engine/packages/epoxy/src/ops/explicit_prepare.rs

@@ -28,7 +28,7 @@ pub async fn epoxy_explicit_prepare(
 	let replica_id = ctx.config().epoxy_replica_id();
 	let instance = &input.instance;
 
-	tracing::info!(
+	tracing::debug!(
 		?instance,
 		"starting explicit prepare for potentially failed replica"
 	);
@@ -317,7 +317,7 @@ async fn restart_phase1(
 		commands: commands.unwrap_or_else(|| vec![]), // Empty vec for no-op
 	};
 
-	tracing::info!(
+	tracing::debug!(
 		?instance,
 		commands_count = proposal.commands.len(),
 		"restarting phase1 with propose operation"

engine/packages/epoxy/src/replica/decide_path.rs

@@ -9,7 +9,7 @@ pub fn decide_path(
 	pre_accept_oks: Vec<protocol::Payload>,
 	payload: &protocol::Payload,
 ) -> Result<protocol::Path> {
-	tracing::info!(instance=?payload.instance, "deciding path");
+	tracing::debug!(instance=?payload.instance, "deciding path");
 
 	let mut new_payload = payload.clone();
 	let mut path = protocol::Path::PathFast(protocol::PathFast {
@@ -29,7 +29,7 @@ pub fn decide_path(
 			// EPaxos Steps 11 (returns PathFast)
 			continue;
 		} else {
-			tracing::info!(?pre_accept_ok.deps, "received dissenting voice");
+			tracing::debug!(?pre_accept_ok.deps, "received dissenting voice");
 
 			// EPaxos Step 13
 			let new_deps = utils::union_deps(new_payload.deps, pre_accept_ok.deps);

engine/packages/epoxy/src/replica/lead_consensus.rs

@@ -12,7 +12,7 @@ pub async fn lead_consensus(
 	replica_id: protocol::ReplicaId,
 	proposal: protocol::Proposal,
 ) -> Result<protocol::Payload> {
-	tracing::info!(?replica_id, "leading consensus");
+	tracing::debug!(?replica_id, "leading consensus");
 
 	// EPaxos Step 1
 	let instance_num_key = keys::replica::InstanceNumberKey;

engine/packages/epoxy/src/replica/message_request.rs

@@ -14,7 +14,7 @@ pub async fn message_request(
 
 	let kind = match request.kind {
 		protocol::RequestKind::UpdateConfigRequest(req) => {
-			tracing::info!(
+			tracing::debug!(
 				epoch = ?req.config.epoch,
 				replica_count = req.config.replicas.len(),
 				"received configuration update request"
@@ -103,7 +103,7 @@ pub async fn message_request(
 		}
 		protocol::RequestKind::CoordinatorUpdateReplicaStatusRequest(req) => {
 			// Send signal to coordinator workflow
-			tracing::info!(
+			tracing::debug!(
 				?current_replica_id,
 				update_replica_id=?req.replica_id,
 				update_status=?req.status,
@@ -124,7 +124,7 @@ pub async fn message_request(
 		}
 		protocol::RequestKind::BeginLearningRequest(req) => {
 			// Send signal to replica workflow
-			tracing::info!(?current_replica_id, "received begin learning request");
+			tracing::debug!(?current_replica_id, "received begin learning request");
 
 			ctx.signal(crate::workflows::replica::BeginLearning {
 				config: req.config.clone().into(),

engine/packages/epoxy/src/replica/messages/accept.rs

@@ -17,7 +17,7 @@ pub async fn accept(
 		instance,
 	} = accept_req.payload;
 
-	tracing::info!(?replica_id, ?instance, "handling accept message");
+	tracing::debug!(?replica_id, ?instance, "handling accept message");
 
 	// Validate ballot
 	let current_ballot = ballot::get_ballot(tx, replica_id).await?;

engine/packages/epoxy/src/replica/messages/accepted.rs

@@ -18,7 +18,7 @@ pub async fn accepted(
 		instance,
 	} = payload;
 
-	tracing::info!(?replica_id, ?instance, "handling accepted message");
+	tracing::debug!(?replica_id, ?instance, "handling accepted message");
 
 	// Create accepted log entry
 	let current_ballot = ballot::get_ballot(tx, replica_id).await?;