diff --git a/mindspore/ccsrc/plugin/device/ascend/hal/device/ascend_data_queue.cc b/mindspore/ccsrc/plugin/device/ascend/hal/device/ascend_data_queue.cc
index 474e1a338bb..73d99509a85 100644
--- a/mindspore/ccsrc/plugin/device/ascend/hal/device/ascend_data_queue.cc
+++ b/mindspore/ccsrc/plugin/device/ascend/hal/device/ascend_data_queue.cc
@@ -671,6 +671,9 @@ void WingmanQueue::Close() {
 std::shared_ptr<BlockingQueue> GetTdtWingManQueue(const std::shared_ptr<AnfNode> &node) {
   if (common::AnfAlgo::GetCNodeName(node) != kGetNextOpName) return nullptr;
   auto queue_name = common::AnfAlgo::GetNodeAttr<std::string>(node, "shared_name");
+  if (!DataQueueMgr::GetInstance().IsCreated(queue_name)) {
+    return nullptr;
+  }
   return DataQueueMgr::GetInstance().GetDataQueue(queue_name);
 }