|
9 | 9 |
|
10 | 10 | timezone = 'Asia/Shanghai' |
11 | 11 |
|
| 12 | +scan_progress = "scan_progress" |
| 13 | + |
12 | 14 | def patch_json(resp): |
13 | 15 | if resp.get("stats", {}).get("running_time_ms"): |
14 | 16 | resp["stats"]["running_time_ms"] = 0 |
| 17 | + |
| 18 | + # flaky value in cluster |
| 19 | + if resp.get("stats", {}).get("scan_progress"): |
| 20 | + resp["stats"]["scan_progress"] = scan_progress |
15 | 21 | return resp |
16 | 22 |
|
17 | 23 | def do_query(query, timeout=10, pagination=None, port=8000, patch=True): |
@@ -138,7 +144,7 @@ def test_query_lifecycle_finalized(rows): |
138 | 144 | "data":[["0"],["1"],["2"],["3"]], |
139 | 145 | "result_timeout_secs":timeout, |
140 | 146 | "stats":{ |
141 | | - "scan_progress":progress, |
| 147 | + "scan_progress": scan_progress, |
142 | 148 | "write_progress": {"rows":0, "bytes": 0}, |
143 | 149 | "result_progress":progress, |
144 | 150 | "total_scan":progress, |
@@ -166,7 +172,7 @@ def test_query_lifecycle_finalized(rows): |
166 | 172 | "state": "Succeeded", |
167 | 173 | "warnings":[], |
168 | 174 | "stats":{ |
169 | | - "scan_progress":progress, |
| 175 | + "scan_progress": scan_progress, |
170 | 176 | "write_progress": {"rows":0, "bytes": 0}, |
171 | 177 | "result_progress":progress, |
172 | 178 | "total_scan":progress, |
|
0 commit comments