diff --git a/tests/pytest/query/query1970YearsAf.py b/tests/pytest/query/query1970YearsAf.py
index 441f835e89ef4e05d93c37151e7e8f71ccbdd03d..9cc8948c2f6f6594f1bfd620df7cabd8b2813667 100644
--- a/tests/pytest/query/query1970YearsAf.py
+++ b/tests/pytest/query/query1970YearsAf.py
@@ -243,10 +243,11 @@ class TDTestCase:
         tdLog.info("==========step3: query join again")
         self.sqlsquery()
 
-    def stop(self):
-        tdSql.close()
         rm_cmd = f"rm -f /tmp/insert* > /dev/null 2>&1"
         _ = subprocess.check_output(rm_cmd, shell=True).decode("utf-8")
+
+    def stop(self):
+        tdSql.close()
         tdLog.success(f"{__file__} successfully executed")
 
 tdCases.addLinux(__file__, TDTestCase())