modified warn statement

Author: parmesant

src/handlers/http/logstream.rs

@@ -103,8 +103,6 @@ pub async fn list(req: HttpRequest) -> Result<impl Responder, StreamError> {
         .unwrap()
         .into_iter()
         .filter(|logstream| {
-            warn!("logstream-\n{logstream:?}");
-
             Users.authorize(key.clone(), Action::ListStream, Some(&logstream.name), None)
                 == crate::rbac::Response::Authorized
         })

src/storage/object_storage.rs

@@ -678,10 +678,8 @@ pub trait ObjectStorage: Debug + Send + Sync + 'static {
         }
 
         // get all streams
-        let streams = STREAM_INFO.list_streams();
-
-        for stream in streams {
-            info!("Starting upload job for stream- {stream}");
+        for stream in STREAM_INFO.list_streams() {
+            info!("Starting object_store_sync for stream- {stream}");
 
             let custom_partition = STREAM_INFO
                 .get_custom_partition(&stream)
@@ -772,7 +770,7 @@ async fn conversion_for_stream(
     stream: String,
     shutdown_signal: bool,
 ) -> Result<(), ObjectStorageError> {
-    info!("Starting conversion job for stream- {stream}");
+    info!("Starting arrow_conversion job for stream- {stream}");
 
     let time_partition = STREAM_INFO
         .get_time_partition(&stream)

src/sync.rs

@@ -53,7 +53,7 @@ where
                 && !warning_issued_clone.load(std::sync::atomic::Ordering::Relaxed)
             {
                 warn!(
-                    "Task '{}' is taking longer than expected: (threshold: {:?})",
+                    "Task '{}' started at: {start_time:?} is taking longer than expected: (threshold: {:?})",
                     task_name, threshold
                 );
                 warning_issued_clone.store(true, std::sync::atomic::Ordering::Relaxed);
@@ -67,7 +67,7 @@ where
             if warning_issued_clone_select.load(std::sync::atomic::Ordering::Relaxed) {
                 let elapsed = start_time.elapsed();
                 warn!(
-                    "Task '{}' took longer than expected: {:?} (threshold: {:?})",
+                    "Task '{}' started at: {start_time:?} took longer than expected: {:?} (threshold: {:?})",
                     task_name, elapsed, threshold
                 );
             }