lint and check action permissions

Author: Flosckow

.github/workflows/codspeed_benchmarks.yaml

@@ -37,11 +37,15 @@ jobs:
         ports:
           - 6379:6379
     steps:
-      - uses: actions/checkout@v4
+      - uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6.0.1
+        with:
+          persist-credentials: false
       - name: Install uv
-        uses: astral-sh/setup-uv@v5
+        - uses: astral-sh/setup-uv@1e862dfacbd1d6d858c55d9b792c756523627244 # v7.1.4
+        with:
+          version: "latest"
       - name: Set up Python
-        uses: actions/setup-python@v5
+        uses: actions/setup-python@83679a892e2d95755f2dac6acb0bfd1e9ac5d548 # v6.1.0
         with:
           python-version: "3.13"
       - name: Install Dependencies
@@ -50,7 +54,8 @@ jobs:
       - name: Install Pydantic v2
         run: uv pip install --system --prerelease=disallow "pydantic>=2.0.0,<3.0.0"
       - name: Run the benchmarks
-        uses: CodSpeedHQ/action@v4
+        uses: GitHubSecurityLab/actions-permissions/monitor@main
+        uses: CodSpeedHQ/action@dbda7111f8ac363564b0c51b992d4ce76bb89f2f # v4.5.2
         with:
           mode: walltime
           run: uv run pytest benchmarks/ --codspeed

benchmarks/confluent_cases/test_basic.py

@@ -51,6 +51,6 @@ async def start(self) -> AsyncIterator[float]:
             yield start_time
 
     async def test_consume_message(self) -> None:
-        async with self.start() as start_time:
+        async with self.start():
             await asyncio.sleep(6.0)
         assert self.EVENTS_PROCESSED > 1

benchmarks/confluent_cases/test_confluent.py

@@ -87,6 +87,6 @@ def handle() -> None:
             await run_in_executor(None, self.consumer.close)
 
     async def test_consume_message(self) -> None:
-        async with self.start() as start_time:
+        async with self.start():
             await asyncio.sleep(6.0)
         assert self.EVENTS_PROCESSED > 1

benchmarks/confluent_cases/test_msgspec.py

@@ -55,6 +55,6 @@ async def start(self) -> AsyncIterator[float]:
             yield start_time
 
     async def test_consume_message(self) -> None:
-        async with self.start() as start_time:
+        async with self.start():
             await asyncio.sleep(6.0)
         assert self.EVENTS_PROCESSED > 1

benchmarks/confluent_cases/test_pydantic.py

@@ -50,6 +50,6 @@ async def start(self) -> AsyncIterator[float]:
             yield start_time
 
     async def test_consume_message(self) -> None:
-        async with self.start() as start_time:
+        async with self.start():
             await asyncio.sleep(6.0)
         assert self.EVENTS_PROCESSED > 1

benchmarks/kafka_cases/test_aiokafka.py

@@ -87,6 +87,6 @@ async def message_loop() -> None:
             await consumer.stop()
 
     async def test_consume_message(self) -> None:
-        async with self.start() as start_time:
+        async with self.start():
             await asyncio.sleep(1)
         assert self.EVENTS_PROCESSED > 1

benchmarks/kafka_cases/test_basic.py

@@ -49,6 +49,6 @@ async def start(self) -> AsyncIterator[float]:
             yield start_time
 
     async def test_consume_message(self) -> None:
-        async with self.start() as start_time:
+        async with self.start():
             await asyncio.sleep(1)
         assert self.EVENTS_PROCESSED > 1

benchmarks/kafka_cases/test_msgspec.py

@@ -55,6 +55,6 @@ async def start(self) -> AsyncIterator[float]:
             yield start_time
 
     async def test_consume_message(self) -> None:
-        async with self.start() as start_time:
+        async with self.start():
             await asyncio.sleep(1)
         assert self.EVENTS_PROCESSED > 1

benchmarks/kafka_cases/test_pydantic.py

@@ -50,6 +50,6 @@ async def start(self) -> AsyncIterator[float]:
             yield start_time
 
     async def test_consume_message(self) -> None:
-        async with self.start() as start_time:
+        async with self.start():
             await asyncio.sleep(1)
         assert self.EVENTS_PROCESSED > 1

benchmarks/nats_cases/test_basic.py

@@ -18,7 +18,7 @@ class TestNatsCase:
     comment = "Consume Any Message"
     broker_type = "NATS"
 
-    def setup_method(self):
+    def setup_method(self) -> None:
         broker = self.broker = NatsBroker(logger=None, graceful_timeout=10)
         self.EVENTS_PROCESSED = 0
 
@@ -48,6 +48,6 @@ async def start(self) -> AsyncIterator[float]:
             yield start_time
 
     async def test_consume_message(self) -> None:
-        async with self.start() as start_time:
+        async with self.start():
             await asyncio.sleep(1)
         assert self.EVENTS_PROCESSED > 1