Upgrade Ubuntu in CI

.github/workflows/ci.yaml

@@ -12,7 +12,7 @@ on:
 jobs:
   linters:
     name: Linting and static analysis
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
     timeout-minutes: 5  # usually 1-2, rarely 3 mins (because of installations)
     steps:
       - uses: actions/checkout@v3
@@ -43,7 +43,7 @@ jobs:
           - install-extras: "uvloop"
             python-version: "3.13"
     name: Python ${{ matrix.python-version }} ${{ matrix.install-extras }}
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
     timeout-minutes: 5  # usually 2-3 mins
     steps:
       - uses: actions/checkout@v3
@@ -83,7 +83,7 @@ jobs:
         install-extras: [ "", "full-auth" ]
         python-version: [ "pypy-3.8", "pypy-3.9", "pypy-3.10" ]
     name: Python ${{ matrix.python-version }} ${{ matrix.install-extras }}
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
     timeout-minutes: 10
     steps:
       - uses: actions/checkout@v3
@@ -103,9 +103,9 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        k3s: [latest, v1.28, v1.27, v1.26]
+        k3s: [latest, v1.31, v1.30, v1.29]
     name: K3s ${{matrix.k3s}}
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
     timeout-minutes: 10  # usually 4-5 mins
     steps:
       - uses: actions/checkout@v3
@@ -122,7 +122,7 @@ jobs:
   coveralls-finish:
     name: Finalize coveralls.io
     needs: [unit-tests, pypy-tests, functional]
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
     steps:
       - uses: actions/setup-python@v4
       - run: pip install coveralls

.github/workflows/thorough.yaml

@@ -16,7 +16,7 @@ on:
 jobs:
   linters:
     name: Linting and static analysis
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
     timeout-minutes: 5  # usually 1-2, rarely 3 mins (because of installations)
     steps:
       - uses: actions/checkout@v3
@@ -47,7 +47,7 @@ jobs:
           - install-extras: "uvloop"
             python-version: "3.12"
     name: Python ${{ matrix.python-version }} ${{ matrix.install-extras }}
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
     timeout-minutes: 5  # usually 2-3 mins
     steps:
       - uses: actions/checkout@v3
@@ -87,7 +87,7 @@ jobs:
         install-extras: [ "", "full-auth" ]
         python-version: [ "pypy-3.8", "pypy-3.9", "pypy-3.10" ]
     name: Python ${{ matrix.python-version }} ${{ matrix.install-extras }}
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
     timeout-minutes: 10
     steps:
       - uses: actions/checkout@v3
@@ -107,9 +107,9 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        k3s: [latest, v1.28, v1.27, v1.26]
+        k3s: [latest, v1.31, v1.30, v1.29]
     name: K3s ${{matrix.k3s}}
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
     timeout-minutes: 10  # usually 4-5 mins
     steps:
       - uses: actions/checkout@v3
@@ -127,9 +127,9 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        k8s: [latest, v1.28.5, v1.27.9, v1.26.13]
+        k8s: [latest, v1.31.2, v1.30.6, v1.29.10]
     name: K8s ${{matrix.k8s}}
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
     timeout-minutes: 10  # usually 4-5 mins
     env:
       K8S: ${{ matrix.k8s }}
@@ -145,7 +145,7 @@ jobs:
   coveralls-finish:
     name: Finalize coveralls.io
     needs: [unit-tests, pypy-tests, functional]
-    runs-on: ubuntu-22.04
+    runs-on: ubuntu-24.04
     steps:
       - uses: actions/setup-python@v4
       - run: pip install coveralls

.readthedocs.yaml

@@ -3,7 +3,7 @@
 version: 2
 formats: all
 build:
-  os: ubuntu-22.04
+  os: ubuntu-24.04
   tools:
     python: "3"
 python:

docs/requirements.txt

@@ -5,6 +5,3 @@ sphinx>=2.0.0
 sphinx-autobuild
 sphinx-autodoc-typehints
 sphinx_rtd_theme>=0.5
-
-# Added 2023-05-06. TODO: Remove when resolved: https://github.com/psf/requests/issues/6432
-urllib3<2.0.0

kopf/_core/intents/callbacks.py

@@ -23,7 +23,7 @@
     IndexingFn = Callable[..., invocation.SyncOrAsync[Optional[object]]]
     WatchingFn = Callable[..., invocation.SyncOrAsync[Optional[object]]]
     ChangingFn = Callable[..., invocation.SyncOrAsync[Optional[object]]]
-    WebhookFn = Callable[..., invocation.SyncOrAsync[None]]
+    WebhookFn = Callable[..., invocation.SyncOrAsync[Optional[object]]]
     DaemonFn = Callable[..., invocation.SyncOrAsync[Optional[object]]]
     TimerFn = Callable[..., invocation.SyncOrAsync[Optional[object]]]
     WhenFilterFn = Callable[..., bool]  # strictly sync, no async!
@@ -145,7 +145,7 @@
             DefaultNamedArg(Any, "param"),
             KwArg(Any),
         ],
-        invocation.SyncOrAsync[None]
+        invocation.SyncOrAsync[Optional[object]]
     ]
 
     DaemonFn = Callable[

kopf/_core/reactor/orchestration.py

@@ -27,11 +27,12 @@
 import functools
 import itertools
 import logging
-from typing import Any, Collection, Container, Dict, Iterable, MutableMapping, NamedTuple, Optional
+from typing import Any, Collection, Container, Dict, Iterable, \
+                   MutableMapping, NamedTuple, Optional, Protocol
 
 from kopf._cogs.aiokits import aiotasks, aiotoggles
 from kopf._cogs.configs import configuration
-from kopf._cogs.structs import references
+from kopf._cogs.structs import bodies, references
 from kopf._core.engines import peering
 from kopf._core.reactor import queueing
 
@@ -43,6 +44,19 @@ class EnsembleKey(NamedTuple):
     namespace: references.Namespace
 
 
+# Differs from queueing.WatchStreamProcessor by the resource=… kwarg.
+class ResourceWatchStreamProcessor(Protocol):
+    async def __call__(
+            self,
+            *,
+            resource: references.Resource,
+            raw_event: bodies.RawEvent,
+            stream_pressure: Optional[asyncio.Event] = None,  # None for tests
+            resource_indexed: Optional[aiotoggles.Toggle] = None,  # None for tests & observation
+            operator_indexed: Optional[aiotoggles.ToggleSet] = None,  # None for tests & observation
+    ) -> None: ...
+
+
 @dataclasses.dataclass
 class Ensemble:
 
@@ -89,7 +103,7 @@ def del_keys(self, keys: Container[EnsembleKey]) -> None:
 
 async def ochestrator(
         *,
-        processor: queueing.WatchStreamProcessor,
+        processor: ResourceWatchStreamProcessor,
         settings: configuration.OperatorSettings,
         identity: peering.Identity,
         insights: references.Insights,
@@ -122,7 +136,7 @@ async def ochestrator(
 # for a simulation of the insights (inputs) and an assertion of the tasks & toggles (outputs).
 async def adjust_tasks(
         *,
-        processor: queueing.WatchStreamProcessor,
+        processor: ResourceWatchStreamProcessor,
         insights: references.Insights,
         settings: configuration.OperatorSettings,
         identity: peering.Identity,
@@ -213,7 +227,7 @@ async def spawn_missing_peerings(
 
 async def spawn_missing_watchers(
         *,
-        processor: queueing.WatchStreamProcessor,
+        processor: ResourceWatchStreamProcessor,
         settings: configuration.OperatorSettings,
         indexed_resources: Container[references.Resource],  # only "if in", never "for in"!
         watched_resources: Iterable[references.Resource],

requirements.txt

@@ -12,7 +12,7 @@ freezegun
 import-linter
 isort
 lxml
-mypy==1.8.0
+mypy==1.13.0
 pre-commit
 pyngrok
 pytest>=6.0.0