diff --git a/src/observer/sql/parser/parse_stage.cpp b/src/observer/sql/parser/parse_stage.cpp
index 56472738821a0636c3e43a0d9b29c51d1eb63cd2..bc96603b027d6d4cbcfe8517474269d847e96bae 100644
--- a/src/observer/sql/parser/parse_stage.cpp
+++ b/src/observer/sql/parser/parse_stage.cpp
@@ -89,14 +89,14 @@ void ParseStage::handle_event(StageEvent *event)
 
   RC rc = handle_request(event);
   if (RC::SUCCESS != rc) {
-    event->done_immediate();
+    callback_event(event, nullptr);
     return;
   }
 
   CompletionCallback *cb = new (std::nothrow) CompletionCallback(this, nullptr);
   if (cb == nullptr) {
     LOG_ERROR("Failed to new callback for SQLStageEvent");
-    event->done_immediate();
+    callback_event(event, nullptr);
     return;
   }