Merge branch 'develop' into myrrc/duckdb-vortex-versoin

Author: myrrc

.agents/skills/samply/scripts/profile_inverted_tree.py

@@ -6,6 +6,7 @@
 import argparse
 import collections
 import re
+from collections.abc import Callable
 from pathlib import Path
 from typing import Any
 
@@ -36,7 +37,7 @@ def thread_matches(thread: dict[str, Any], thread_re: re.Pattern[str] | None, ti
     return bool(thread_re.search(str(thread.get("name", ""))) or thread_re.search(str(thread.get("tid", ""))))
 
 
-def frame_labels(thread: dict[str, Any], symbols: dict[str, str]) -> Any:
+def frame_labels(thread: dict[str, Any], symbols: dict[str, str]) -> Callable[[int], str]:
     cache: dict[int, str] = {}
 
     def label(frame_index: int) -> str:

.agents/skills/samply/scripts/profile_summary.py

@@ -22,14 +22,14 @@ def load_profile(path: Path) -> dict[str, Any]:
         return json.load(f)
 
 
-def value_at(table: dict[str, Any], key: str, index: int, default: Any = None) -> Any:
+def value_at(table: dict[str, Any], key: str, index: int, default: object = None) -> object:
     values = table.get(key)
     if not isinstance(values, list) or index < 0 or index >= len(values):
         return default
     return values[index]
 
 
-def decode_string(thread: dict[str, Any], value: Any) -> str:
+def decode_string(thread: dict[str, Any], value: object) -> str:
     strings = thread.get("stringArray") or []
     if isinstance(value, int) and 0 <= value < len(strings):
         return str(strings[value])
@@ -38,7 +38,7 @@ def decode_string(thread: dict[str, Any], value: Any) -> str:
     return str(value)
 
 
-def resource_name(thread: dict[str, Any], resource_index: Any) -> str:
+def resource_name(thread: dict[str, Any], resource_index: object) -> str:
     if not isinstance(resource_index, int):
         return ""
     resource_table = thread.get("resourceTable") or {}
@@ -72,7 +72,7 @@ def frame_label(thread: dict[str, Any], frame_index: int, symbols: dict[str, str
     return label
 
 
-def expand_stack(thread: dict[str, Any], stack_index: Any) -> list[int]:
+def expand_stack(thread: dict[str, Any], stack_index: object) -> list[int]:
     if not isinstance(stack_index, int):
         return []
 

.github/scripts/close_fixed_fuzzer_issues.py

@@ -30,7 +30,7 @@ class FuzzerIssue:
     body: str
 
 
-def run(cmd: list[str], **kwargs) -> subprocess.CompletedProcess:
+def run(cmd: list[str], **kwargs: object) -> subprocess.CompletedProcess:
     """Run a command, printing it for visibility."""
     print(f"  $ {' '.join(cmd)}", flush=True)
     return subprocess.run(cmd, **kwargs)

.github/scripts/fuzz_report/cli.py

@@ -41,7 +41,7 @@ def _write_github_output(key: str, value: str) -> None:
             f.write(f"{key}={value}\n")
 
 
-def _run_gh(cmd: list[str], *, retries: int = 1, **kwargs) -> subprocess.CompletedProcess:
+def _run_gh(cmd: list[str], *, retries: int = 1, **kwargs: object) -> subprocess.CompletedProcess:
     """Run a gh CLI command with logging and retry on failure.
 
     Prints the command before execution and surfaces stderr on failure.

.github/scripts/fuzz_report/template.py

@@ -9,10 +9,10 @@
 class _NotSetUndefined(Undefined):
     """Jinja2 undefined that renders as '(not set)' and is falsy."""
 
-    def __str__(self):
+    def __str__(self) -> str:
         return "(not set)"
 
-    def __bool__(self):
+    def __bool__(self) -> bool:
         return False
 
 

.github/scripts/fuzz_report/tests/conftest.py

@@ -2,20 +2,21 @@
 
 import json
 import tempfile
+from collections.abc import Iterator
 from pathlib import Path
 
 import pytest
 
 
 @pytest.fixture
-def temp_dir():
+def temp_dir() -> Iterator[Path]:
     """Create a temporary directory."""
     with tempfile.TemporaryDirectory() as d:
         yield Path(d)
 
 
 @pytest.fixture
-def sample_log_content():
+def sample_log_content() -> str:
     """Sample fuzzer log content with index out of bounds crash."""
     return """
 Running: cargo +nightly fuzz run file_io
@@ -37,7 +38,7 @@ def sample_log_content():
 
 
 @pytest.fixture
-def sample_issues():
+def sample_issues() -> list[dict[str, object]]:
     """Sample existing issues for dedup testing."""
     return [
         {
@@ -56,7 +57,7 @@ def sample_issues():
 
 
 @pytest.fixture
-def issues_file(sample_issues, temp_dir):
+def issues_file(sample_issues, temp_dir) -> Path:
     """Write sample issues to a temporary JSON file."""
     path = temp_dir / "issues.json"
     path.write_text(json.dumps(sample_issues))