diff --git a/cpp/src/worker.cpp b/cpp/src/worker.cpp
index a7b04e03..fe63ed64 100644
--- 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
index 616abd7a..859c8013 100644
--- 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;
   }