diff --git a/src/DataStreams/RemoteQueryExecutor.cpp b/src/DataStreams/RemoteQueryExecutor.cpp
index e25a69a34cb..45e50b1a1bd 100644
--- a/src/DataStreams/RemoteQueryExecutor.cpp
+++ b/src/DataStreams/RemoteQueryExecutor.cpp
@@ -217,7 +217,7 @@ std::variant<Block, int> RemoteQueryExecutor::read(std::unique_ptr<ReadContext>
 
     do
     {
-        if (!read_context->resumeRoutine(was_cancelled_mutex))
+        if (!read_context->resumeRoutine())
             return Block();
 
         if (read_context->is_read_in_progress)
@@ -312,7 +312,7 @@ void RemoteQueryExecutor::finish(std::unique_ptr<ReadContext> * read_context)
         return;
 
     if (read_context && *read_context)
-        (*read_context)->cancel(was_cancelled_mutex);
+        (*read_context)->cancel();
 
     /** If you have not read all the data yet, but they are no longer needed.
       * This may be due to the fact that the data is sufficient (for example, when using LIMIT).
@@ -363,7 +363,7 @@ void RemoteQueryExecutor::cancel(std::unique_ptr<ReadContext> * read_context)
         return;
 
     if (read_context && *read_context)
-        (*read_context)->cancel(was_cancelled_mutex);
+        (*read_context)->cancel();
 
     tryCancel("Cancelling query");
 }