add test

dm/openapi/spec/dm.yaml

@@ -1828,6 +1828,7 @@ components:
         - Stopped
         - Running
         - Finished
+        - Paused
     Task:
       description: "task"
       type: object

dm/tests/openapi/client/openapi_task_check

@@ -452,6 +452,24 @@ def check_load_task_finished_status_success(task_name, finished_bytes, total_byt
         assert load_status.get("finished_bytes") == int(finished_bytes)
         assert load_status.get("total_bytes") == int(total_bytes)
 
+def check_dump_task_finished_status_success(task_name, completed_tables, total_tables, estimate_total_rows,finished_rows,finished_bytes):
+    url = API_ENDPOINT + "/" + task_name + "/status"
+    resp = requests.get(url=url)
+    data = resp.json()
+    assert resp.status_code == 200
+    print("check_dump_task_finished_status_success resp=", data)
+
+    for item in data.get("data", []):
+        # Only validate dump task status
+        assert item.get("unit") == "Dump"
+        assert item.get("stage") == "Finished"
+        dump_status = item.get("dump_status", {})
+        assert dump_status.get("progress") == "100.00 %"
+        assert dump_status.get("completed_tables") == int(completed_tables)
+        assert dump_status.get("total_tables") == int(total_tables)
+        assert dump_status.get("estimate_total_rows") == int(estimate_total_rows)
+        assert dump_status.get("finished_rows") == int(finished_rows)
+        assert dump_status.get("finished_bytes") == int(finished_bytes)
 
 def check_task_stage_success(task_name, total, stage):
     url = API_ENDPOINT + "/" + task_name + "/status"
@@ -818,9 +836,10 @@ if __name__ == "__main__":
         "check_noshard_task_dump_status_success": check_noshard_task_dump_status_success,
         "do_complex_operations": do_complex_operations,
         "create_task_with_precheck": create_task_with_precheck,
+        "check_task_stage_success": check_task_stage_success,
         "check_sync_task_status_success": check_sync_task_status_success,
         "check_load_task_finished_status_success": check_load_task_finished_status_success,
-        "check_task_stage_success": check_task_stage_success,
+        "check_dump_task_finished_status_success": check_dump_task_finished_status_success,
     }
 
     func = FUNC_MAP[sys.argv[1]]

dm/tests/openapi/run.sh

@@ -28,6 +28,9 @@ function init_dump_data() {
 
 	run_sql_source1 "CREATE TABLE openapi.t1(i TINYINT, j INT UNIQUE KEY);"
 	run_sql_source1 "INSERT INTO openapi.t1(i,j) VALUES (1, 2),(3,4);"
+
+	run_sql_source1 "CREATE TABLE openapi.t2(i TINYINT, j INT UNIQUE KEY);"
+	run_sql_source1 "INSERT INTO openapi.t2(i,j) VALUES (1, 2),(3,4);"
 }
 
 function init_shard_data() {
@@ -209,6 +212,7 @@ function test_dump_task() {
 	run_dm_ctl_with_retry $WORK_DIR "127.0.0.1:$MASTER_PORT" \
 		"query-status $task_name" \
 		"\"stage\": \"Stopped\"" 1
+	openapi_task_check "check_task_stage_success" $task_name 1 "Stopped"
 
 	init_dump_data
 
@@ -222,6 +226,7 @@ function test_dump_task() {
 	run_dm_ctl_with_retry $WORK_DIR "127.0.0.1:$MASTER_PORT" \
 		"query-status $task_name" 100 \
 		"\"stage\": \"Finished\"" 1
+	openapi_task_check "check_dump_task_finished_status_success" $task_name 2 2 4 4 228
 
 	clean_cluster_sources_and_tasks
 	echo ">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>TEST OPENAPI: dump TASK"
@@ -258,7 +263,7 @@ function test_full_mode_task() {
 	openapi_task_check "check_task_stage_success" $task_name 2 "Stopped"
 
 	init_noshard_data
-	
+
 	# start task success
 	openapi_task_check "start_task_success" $task_name ""
 	run_dm_ctl_with_retry $WORK_DIR "127.0.0.1:$MASTER_PORT" \