From aff3f292a7a8ff8cadd803449121e9d648b80ce2 Mon Sep 17 00:00:00 2001
From: Gabriel <gabrielleebuaa@gmail.com>
Date: Mon, 22 Jul 2024 18:22:22 +0800
Subject: [PATCH] [fix](pipeline) Fix blocked tasks if query is canceled before
 opening (#38200)

## Proposed changes

pick #38206

<!--Describe your changes.-->
---
 be/src/pipeline/pipeline_x/pipeline_x_task.cpp | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/be/src/pipeline/pipeline_x/pipeline_x_task.cpp b/be/src/pipeline/pipeline_x/pipeline_x_task.cpp
index b13cd8c9c6177c..b723fe02d7acab 100644
--- a/be/src/pipeline/pipeline_x/pipeline_x_task.cpp
+++ b/be/src/pipeline/pipeline_x/pipeline_x_task.cpp
@@ -162,6 +162,9 @@ Status PipelineXTask::_extract_dependencies() {
         write_dependencies.swap(_write_dependencies);
         finish_dependencies.swap(_finish_dependencies);
     }
+    if (query_context()->is_cancelled()) {
+        clear_blocking_state();
+    }
     return Status::OK();
 }