diff --git a/application/apps/indexer/session/src/handlers/observe.rs b/application/apps/indexer/session/src/handlers/observe.rs
index 00a1ef62b0..aea086126b 100644
--- a/application/apps/indexer/session/src/handlers/observe.rs
+++ b/application/apps/indexer/session/src/handlers/observe.rs
@@ -27,7 +27,7 @@ pub async fn start_observing(
         ObserveOrigin::File(uuid, file_origin, filename) => {
             let (is_text, session_file_origin) = (
                 matches!(options.parser, ParserType::Text),
-                state.get_session_file_stage().await?,
+                state.get_session_file_origin().await?,
             );
             match session_file_origin {
                 Some(origin) if origin.is_linked() => Err(NativeError {
diff --git a/application/apps/indexer/session/src/state/api.rs b/application/apps/indexer/session/src/state/api.rs
index d83dbadfac..963b620b0d 100644
--- a/application/apps/indexer/session/src/state/api.rs
+++ b/application/apps/indexer/session/src/state/api.rs
@@ -379,7 +379,7 @@ impl SessionStateAPI {
         self.exec_operation(Api::FlushSessionFile(tx), rx).await?
     }
 
-    pub async fn get_session_file_stage(&self) -> Result<Option<SessionFileOrigin>, NativeError> {
+    pub async fn get_session_file_origin(&self) -> Result<Option<SessionFileOrigin>, NativeError> {
         let (tx, rx) = oneshot::channel();
         self.exec_operation(Api::GetSessionFileOrigin(tx), rx)
             .await?