Add DispatcherConfig model read from .ddev/config.toml (DataDog#24434)

* Add DispatcherConfig model read from .ddev/config.toml

Holds max_jobs_per_batch, global_timeout_seconds, and the GitHub rate limits (RateLimiterFactoryConfig). Loaded via the /dispatcher JSON pointer of the repo config.

* Add changelog entry for DataDog#24434

* Type-annotate test fixture and functions

* Document the batch and timeout defaults

* Drop -> None return annotations from tests

* Make the changelog entry a patch-level fixed entry

* Cap max_jobs_per_batch at the safe workflow maximum

Author: AAraKKe

ddev/changelog.d/24434.fixed

@@ -0,0 +1 @@
+Add an internal DispatcherConfig model for reading Dispatcher settings from the repo config.

ddev/src/ddev/cli/ci/tests/dispatcher_config.py

@@ -0,0 +1,30 @@
+# (C) Datadog, Inc. 2026-present
+# All rights reserved
+# Licensed under a 3-clause BSD style license (see LICENSE)
+"""Per-repository Dispatcher configuration read from `.ddev/config.toml`."""
+
+from __future__ import annotations
+
+from typing import TYPE_CHECKING
+
+from pydantic import BaseModel, ConfigDict, Field
+
+from ddev.cli.ci.tests.rate_limiting import RateLimiterFactoryConfig
+
+if TYPE_CHECKING:
+    from ddev.repo.config import RepositoryConfig
+
+
+class DispatcherConfig(BaseModel):
+    """Per-repository Dispatcher configuration."""
+
+    model_config = ConfigDict(frozen=True, extra="forbid")
+
+    max_jobs_per_batch: int = Field(default=240, gt=0, le=240)  # 256 GitHub job cap - 16-job setup buffer; the safe max
+    global_timeout_seconds: float = Field(default=10800.0, gt=0)  # 3 hours
+    github_rate_limits: RateLimiterFactoryConfig = RateLimiterFactoryConfig()
+
+    @classmethod
+    def from_repo_config(cls, repo_config: RepositoryConfig) -> DispatcherConfig:
+        """Build a DispatcherConfig from the `/dispatcher` table of `.ddev/config.toml`."""
+        return cls(**repo_config.get("/dispatcher", {}))

ddev/tests/cli/ci/tests/test_dispatcher_config.py

@@ -0,0 +1,84 @@
+# (C) Datadog, Inc. 2026-present
+# All rights reserved
+# Licensed under a 3-clause BSD style license (see LICENSE)
+"""Tests for DispatcherConfig.from_repo_config."""
+
+from __future__ import annotations
+
+from collections.abc import Callable
+
+import pytest
+
+from ddev.cli.ci.tests.dispatcher_config import DispatcherConfig
+from ddev.cli.ci.tests.rate_limiting import RateLimiterFactoryConfig
+from ddev.repo.config import RepositoryConfig
+from ddev.utils.fs import Path
+
+RepoConfigBuilder = Callable[[str], RepositoryConfig]
+
+
+@pytest.fixture
+def repo_config(tmp_path: Path) -> RepoConfigBuilder:
+    def build(toml_content: str) -> RepositoryConfig:
+        config_path = Path(tmp_path) / "config.toml"
+        config_path.write_text(toml_content)
+        return RepositoryConfig(config_path)
+
+    return build
+
+
+def test_from_repo_config_reads_full_dispatcher_table(repo_config: RepoConfigBuilder):
+    config = repo_config(
+        """
+        [dispatcher]
+        max_jobs_per_batch = 120
+        global_timeout_seconds = 3600.0
+
+        [dispatcher.github_rate_limits]
+        total_hourly_max_rate = 1500
+        slow_integrations = ["mongo", "mysql"]
+
+        [dispatcher.github_rate_limits.default]
+        max_rate = 360
+
+        [dispatcher.github_rate_limits.slow]
+        max_rate = 120
+        """
+    )
+
+    result = DispatcherConfig.from_repo_config(config)
+
+    assert result.max_jobs_per_batch == 120
+    assert result.global_timeout_seconds == 3600.0
+    assert result.github_rate_limits.total_hourly_max_rate == 1500
+    assert result.github_rate_limits.slow_integrations == frozenset({"mongo", "mysql"})
+    assert result.github_rate_limits.default.max_rate == 360
+    assert result.github_rate_limits.slow.max_rate == 120
+
+
+def test_from_repo_config_reads_scalars_without_rate_limits_subtable(repo_config: RepoConfigBuilder):
+    config = repo_config(
+        """
+        [dispatcher]
+        max_jobs_per_batch = 120
+        global_timeout_seconds = 3600.0
+        """
+    )
+
+    result = DispatcherConfig.from_repo_config(config)
+
+    assert result.max_jobs_per_batch == 120
+    assert result.global_timeout_seconds == 3600.0
+    assert result.github_rate_limits == RateLimiterFactoryConfig()
+
+
+def test_from_repo_config_falls_back_to_defaults_when_dispatcher_table_missing(repo_config: RepoConfigBuilder):
+    config = repo_config(
+        """
+        validations = []
+        """
+    )
+
+    result = DispatcherConfig.from_repo_config(config)
+
+    assert result == DispatcherConfig()