microbench：string 索引补 name(10)（Nebula 3.x），compact 超时与诊断对齐 harness。

Author: rockeet

microbench/lookup.py

@@ -32,8 +32,10 @@ def load_lookup_data(suite: MicrobenchSuite) -> None:
     suite.wait_space_ready(LOOKUP_SPACE)
     resp = suite.execute("CREATE TAG IF NOT EXISTS person(name string, age int)")
     suite.check_resp_succeeded(resp)
+    # 原版为 person(name)；Nebula 3.x 变长 string 索引必须带长度（与 YIELD 同类适配）。
+    # length=10 对齐 data_generate.random_string(10)。
     resp = suite.execute(
-        "CREATE TAG INDEX IF NOT EXISTS personName ON person(name)"
+        "CREATE TAG INDEX IF NOT EXISTS personName ON person(name(10))"
     )
     suite.check_resp_succeeded(resp)
     resp = suite.execute(

microbench/suite.py

@@ -329,9 +329,11 @@ def record_storage_stage(self, stage: str) -> dict[str, Any]:
     def run_compact_job(
         self,
         space: str,
-        timeout_sec: float = 1800.0,
+        timeout_sec: Optional[float] = None,
         poll_interval: float = 2.0,
     ) -> dict[str, Any]:
+        if timeout_sec is None:
+            timeout_sec = float(os.environ.get("MICROBENCH_COMPACT_TIMEOUT", "3600"))
         started = time.monotonic()
         self.check_resp_succeeded(self.execute(f"USE `{space}`"))
         resp = self.execute("SUBMIT JOB COMPACT")
@@ -364,8 +366,24 @@ def run_compact_job(
                 break
             time.sleep(poll_interval)
         else:
+            # Harness diagnostics only; do not alter compact semantics.
+            jobs_diag = ""
+            try:
+                all_jobs = self.execute("SHOW JOBS")
+                if all_jobs.is_succeeded():
+                    rows = []
+                    jkeys = _keys(all_jobs)
+                    for i in range(min(all_jobs.row_size(), 20)):
+                        cells = _row_cells(all_jobs.row_values(i))
+                        rows.append(
+                            {jkeys[j]: _cell_str(cells[j]) for j in range(len(jkeys))}
+                        )
+                    jobs_diag = f" SHOW JOBS(sample)={rows}"
+            except Exception as exc:  # noqa: BLE001
+                jobs_diag = f" SHOW JOBS failed: {exc}"
             raise RuntimeError(
                 f"timeout waiting for COMPACT job {job_id} last={last_status}"
+                f"{jobs_diag}"
             )
         if last_status != "FINISHED":
             raise RuntimeError(f"COMPACT job {job_id} ended with {last_status}")