diff --git a/source/libs/executor/src/anomalywindowoperator.c b/source/libs/executor/src/anomalywindowoperator.c
index 425809e1a2..45d9d90928 100644
--- a/source/libs/executor/src/anomalywindowoperator.c
+++ b/source/libs/executor/src/anomalywindowoperator.c
@@ -327,7 +327,7 @@ static int32_t anomalyParseJson(SJson* pJson, SArray* pWindows, const char* pId)
       qError("%s failed to exec forecast, msg:%s", pId, pMsg);
     }
 
-    return TSDB_CODE_ANA_INTERNAL_ERROR;
+    return TSDB_CODE_ANA_ANODE_RETURN_ERROR;
   } else if (rows == 0) {
     return TSDB_CODE_SUCCESS;
   }
diff --git a/source/libs/executor/src/forecastoperator.c b/source/libs/executor/src/forecastoperator.c
index b0966a65fe..25052af523 100644
--- a/source/libs/executor/src/forecastoperator.c
+++ b/source/libs/executor/src/forecastoperator.c
@@ -235,7 +235,7 @@ static int32_t forecastAnalysis(SForecastSupp* pSupp, SSDataBlock* pBlock, const
     }
 
     tjsonDelete(pJson);
-    return TSDB_CODE_ANA_INTERNAL_ERROR;
+    return TSDB_CODE_ANA_ANODE_RETURN_ERROR;
   }
 
   if (code < 0) {
diff --git a/tools/tdgpt/taosanalytics/test/unit_test.py b/tools/tdgpt/taosanalytics/test/unit_test.py
index 5ff1717b5f..1dd9e91969 100644
--- a/tools/tdgpt/taosanalytics/test/unit_test.py
+++ b/tools/tdgpt/taosanalytics/test/unit_test.py
@@ -17,7 +17,7 @@ class UtilTest(unittest.TestCase):
     def test_generate_anomaly_window(self):
         # Test case 1: Normal input
         wins = convert_results_to_windows([1, 1, 1, 1, 1, 1, -1, -1, -1, 1, 1, -1],
-                                          [1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12])
+                                          [1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12], 1)
         print(f"The result window is:{wins}")
 
         # Assert the number of windows
@@ -30,15 +30,15 @@ class UtilTest(unittest.TestCase):
         self.assertListEqual(wins[1], [12, 12])
 
         # Test case 2: Anomaly input list is empty
-        wins = convert_results_to_windows([], [1, 2])
+        wins = convert_results_to_windows([], [1, 2], 1)
         self.assertListEqual(wins, [])
 
         # Test case 3: Anomaly input list is None
-        wins = convert_results_to_windows([], None)
+        wins = convert_results_to_windows([], None, 1)
         self.assertListEqual(wins, [])
 
         # Test case 4: Timestamp list is None
-        wins = convert_results_to_windows(None, [])
+        wins = convert_results_to_windows(None, [], 1)
         self.assertListEqual(wins, [])
 
     def test_validate_input_data(self):