Merge pull request #210 from kpn/fix/bump-deps

fix: bump dependencies

.github/workflows/bumpversion.yml

@@ -7,7 +7,7 @@ on:
 
 jobs:
   bump-version:
-    if: "!startsWith(github.event.head_commit.message, 'bump:')"
+    if: ${{ !startsWith(github.event.head_commit.message, 'bump:') }}
     runs-on: ubuntu-latest
     name: "Bump version and create changelog with commitizen"
     steps:

.github/workflows/pr-tests.yaml

@@ -21,7 +21,7 @@ jobs:
     runs-on: ubuntu-latest
     strategy:
       matrix:
-        python-version: ['3.8', '3.9', '3.10', '3.11', '3.12']
+        python-version: ['3.8', '3.9', '3.10', '3.11', '3.12', '3.13']
     steps:
     - uses: actions/checkout@v3
       with:

kstreams/prometheus/monitor.py

@@ -132,7 +132,7 @@ def clean_stream_consumer_metrics(self, consumer: Consumer) -> None:
             partition = topic_partition.partition
 
             metrics_found = False
-            for sample in self.MET_LAG.collect()[0].samples:
+            for sample in list(self.MET_LAG.collect())[0].samples:
                 if {
                     "topic": topic,
                     "partition": str(partition),

kstreams/streams.py

@@ -428,6 +428,13 @@ async def __anext__(self) -> ConsumerRecord:
         except errors.ConsumerStoppedError:
             raise StopAsyncIteration  # noqa: F821
 
+    async def __call__(self, *args, **kwargs) -> typing.Any:
+        """Make stream work as the wrapped func to keep behavior.
+
+        This allows for testing the stream as a normal function.
+        """
+        return self.func(*args, **kwargs)
+
 
 def stream(
     topics: typing.Union[typing.List[str], str],