Merge pull request #44 from haochenpan/pre-commit-ci-update-config

[pre-commit.ci] pre-commit autoupdate
haochenpan · Dec 2, 2024 · 464a81e · 464a81e
2 parents d7d5f0f + 6732502
commit 464a81e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 7 deletions.
diff --git a/.pre-commit-config.yaml b/.pre-commit-config.yaml
@@ -19,15 +19,15 @@ repos:
     hooks:
       - id: codespell
   - repo: https://github.com/nbQA-dev/nbQA
-    rev: 1.8.7
+    rev: 1.9.1
     hooks:
       - id: nbqa-ruff
   - repo: https://github.com/kynan/nbstripout
-    rev: 0.7.1
+    rev: 0.8.1
     hooks:
       - id: nbstripout
   - repo: 'https://github.com/charliermarsh/ruff-pre-commit'
-    rev: v0.7.1
+    rev: v0.8.0
     hooks:
       - id: ruff
         args:

diff --git a/action_provider/action_consume.py b/action_provider/action_consume.py
@@ -127,11 +127,9 @@ def filter_messages_on_ts(
     ts: int,
 ) -> dict[str, list[dict[str, Any]]]:
     """Update the messages dictionary with the list of filters."""
-    for topic_partition in messages:
+    for topic_partition, topic_messages in messages.items():
         messages[topic_partition] = [
-            message
-            for message in messages[topic_partition]
-            if message['timestamp'] >= ts
+            message for message in topic_messages if message['timestamp'] >= ts
         ]
     return messages