modified warn statement

Author: parmesant

src/handlers/http/logstream.rs

@@ -102,8 +102,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), None)
                 == crate::rbac::Response::Authorized
         })

src/storage/object_storage.rs

@@ -680,10 +680,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)
@@ -774,7 +772,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

@@ -54,7 +54,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);
@@ -68,7 +68,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
                 );
             }