ci: Update pre-commit configs and apply auto-fixes

.pre-commit-config.yaml

@@ -20,3 +20,7 @@ repos:
   rev: v1.5.1
   hooks:
   - id: mypy
+    additional_dependencies: [
+      'types-python-dateutil',
+      'attrs>=21.3',
+    ]

scripts/extract-release-changelog.py

@@ -45,12 +45,14 @@ def main():
         if m is not None:
             content = m.group(1).strip()
             content += (
-                "\n\n### Full Changelog\n\nCheck out [the full changelog](%s) until this release (%s).\n"
-                % (changelog_url, tag)
+                f"\n\n### Full Changelog"
+                f"\n\nCheck out [the full changelog]({changelog_url}) "
+                f"until this release ({tag}).\n"
             )
             content += (
-                "\n\n### Full Commit Logs\n\nCheck out [the full commit logs](%s) between release (%s) and (%s).\n"
-                % (commitlog_url, prev_tag, tag)
+                f"\n\n### Full Commit Logs"
+                f"\n\nCheck out [the full commit logs]({commitlog_url}) "
+                f"between release ({prev_tag}) and ({tag}).\n"
             )
             if not args.draft:
                 output_path.write_text(content)

src/callosum/lower/dispatch_redis.py

@@ -31,7 +31,6 @@ class RedisStreamAddress(AbstractAddress):
 
 
 class DispatchRedisConnection(AbstractConnection):
-
     __slots__ = ("transport",)
 
     transport: DispatchRedisTransport
@@ -54,8 +53,10 @@ async def recv_message(self) -> AsyncGenerator[Optional[RawHeaderBody], None]:
             stream_key = self.addr.stream_key
         else:
             stream_key = f"{self.addr.stream_key}.{self.direction_keys[0]}"
+
         # _s = asyncio.shield
-        _s = lambda x: x
+        def _s(x):
+            return x
 
         async def _xack(raw_msg):
             await self.transport._redis.xack(raw_msg[0], self.addr.group, raw_msg[1])
@@ -87,8 +88,11 @@ async def send_message(self, raw_msg: RawHeaderBody) -> None:
             stream_key = self.addr.stream_key
         else:
             stream_key = f"{self.addr.stream_key}.{self.direction_keys[1]}"
+
         # _s = asyncio.shield
-        _s = lambda x: x
+        def _s(x):
+            return x
+
         await _s(
             self.transport._redis.xadd(
                 stream_key, {b"hdr": raw_msg[0], b"msg": raw_msg[1]}

src/callosum/lower/rpc_redis.py

@@ -25,7 +25,6 @@ class RedisStreamAddress(AbstractAddress):
 
 
 class RPCRedisConnection(AbstractConnection):
-
     __slots__ = ("transport",)
 
     transport: RPCRedisTransport
@@ -48,8 +47,10 @@ async def recv_message(self) -> AsyncGenerator[Optional[RawHeaderBody], None]:
             stream_key = self.addr.stream_key
         else:
             stream_key = f"{self.addr.stream_key}.{self.direction_keys[0]}"
+
         # _s = asyncio.shield
-        _s = lambda x: x
+        def _s(x):
+            return x
 
         async def _xack(raw_msg):
             await self.transport._redis.xack(raw_msg[0], self.addr.group, raw_msg[1])
@@ -81,8 +82,11 @@ async def send_message(self, raw_msg: RawHeaderBody) -> None:
             stream_key = self.addr.stream_key
         else:
             stream_key = f"{self.addr.stream_key}.{self.direction_keys[1]}"
+
         # _s = asyncio.shield
-        _s = lambda x: x
+        def _s(x):
+            return x
+
         await _s(
             self.transport._redis.xadd(
                 stream_key, {b"hdr": raw_msg[0], b"msg": raw_msg[1]}