From 525c12658fcd0ac076916716e1bbb9b51d323897 Mon Sep 17 00:00:00 2001
From: Ahmed Farghal <me@asoli.dev>
Date: Fri, 31 May 2024 14:48:58 +0100
Subject: [PATCH] reduce logging level of task center

Also removes an incorrect debug "shutting down" log from partition processor manager
---
 crates/core/src/task_center.rs                   | 6 +++---
 crates/worker/src/partition_processor_manager.rs | 1 -
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git a/crates/core/src/task_center.rs b/crates/core/src/task_center.rs
index 5208fcc7c..813b2d5d5 100644
--- a/crates/core/src/task_center.rs
+++ b/crates/core/src/task_center.rs
@@ -394,7 +394,7 @@ impl TaskCenter {
         let cancel = cancellation_token().child_token();
         let result = self.spawn_inner(kind, name, partition_id, cancel, future);
 
-        debug!(
+        trace!(
             kind = ?parent_kind,
             name = ?parent_name,
             child_kind = ?kind,
@@ -462,7 +462,7 @@ impl TaskCenter {
                     join_handle.abort();
                 } else if task_kind.should_wait_on_cancel() {
                     // Give the task a chance to finish before logging.
-                    if tokio::time::timeout(Duration::from_secs(1), &mut join_handle)
+                    if tokio::time::timeout(Duration::from_secs(2), &mut join_handle)
                         .await
                         .is_err()
                     {
@@ -737,7 +737,7 @@ async fn wrapper<F>(
 ) where
     F: Future<Output = anyhow::Result<()>> + Send + 'static,
 {
-    debug!(kind = ?kind, name = ?task.name, "Starting task {}", task_id);
+    trace!(kind = ?kind, name = ?task.name, "Starting task {}", task_id);
 
     let result = CURRENT_TASK_CENTER
         .scope(
diff --git a/crates/worker/src/partition_processor_manager.rs b/crates/worker/src/partition_processor_manager.rs
index def65b296..bc5dc84ab 100644
--- a/crates/worker/src/partition_processor_manager.rs
+++ b/crates/worker/src/partition_processor_manager.rs
@@ -213,7 +213,6 @@ impl PartitionProcessorManager {
             tokio::select! {
                 Some(command) = self.rx.recv() => {
                     self.on_command(command);
-                    debug!("PartitionProcessorManager shutting down");
                 }
                 Some(get_state) = self.incoming_get_state.next() => {
                     self.on_get_state(get_state);