Downgrade worker progress thread start/stop log to debug

pentschev · Oct 30, 2023 · 1550d3a · 1550d3a
1 parent 130815d
commit 1550d3a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/cpp/src/worker.cpp b/cpp/src/worker.cpp
@@ -355,7 +355,7 @@ void Worker::setProgressThreadStartCallback(std::function<void(void*)> callback,
 void Worker::startProgressThread(const bool pollingMode, const int epollTimeout)
 {
   if (_progressThread) {
-    ucxx_warn("Worker progress thread already running");
+    ucxx_debug("Worker progress thread already running");
     return;
   }
 
@@ -390,7 +390,7 @@ void Worker::stopProgressThreadNoWarn() { _progressThread = nullptr; }
 void Worker::stopProgressThread()
 {
   if (!_progressThread)
-    ucxx_warn("Worker progress thread not running or already stopped");
+    ucxx_debug("Worker progress thread not running or already stopped");
   else
     stopProgressThreadNoWarn();
 }

diff --git a/cpp/src/worker_progress_thread.cpp b/cpp/src/worker_progress_thread.cpp
@@ -52,7 +52,7 @@ WorkerProgressThread::WorkerProgressThread(
 WorkerProgressThread::~WorkerProgressThread()
 {
   if (!_thread.joinable()) {
-    ucxx_warn("Worker progress thread not running or already stopped");
+    ucxx_debug("Worker progress thread not running or already stopped");
     return;
   }