Update black formatter version.

.pre-commit-config.yaml

@@ -13,7 +13,7 @@ repos:
       - id: requirements-txt-fixer
 
   - repo: https://github.com/psf/black
-    rev: 23.1.0
+    rev: 24.1.1
     hooks:
       - id: black
 

dp3/.core_modules/update_planner.py

@@ -6,6 +6,7 @@
 Note:
     Core modules needs to be enabled in worker.py and not in config!
 """
+
 import logging
 from datetime import timedelta
 

dp3/bin/config.py

@@ -1,4 +1,5 @@
 """DP3 Setup Config Script for creating a DP3 application."""
+
 import shutil
 import sys
 from pathlib import Path

dp3/bin/setup.py

@@ -1,4 +1,5 @@
 """DP3 Setup Script for creating a DP3 application."""
+
 import argparse
 import contextlib
 import shutil

dp3/common/config.py

@@ -1,6 +1,7 @@
 """
 Platform config file reader and config model.
 """
+
 import os
 from typing import Annotated, Optional, Union
 

dp3/common/control.py

@@ -1,6 +1,7 @@
 """
 Module enabling remote control of the platform's internal events.
 """
+
 import logging
 from enum import Enum
 from typing import Callable

dp3/common/entityspec.py

@@ -5,8 +5,7 @@
 from dp3.common.types import ParsedTimedelta
 
 
-class SpecModel(BaseModel, extra=Extra.forbid):
-    ...
+class SpecModel(BaseModel, extra=Extra.forbid): ...
 
 
 class ImmortalLifetime(SpecModel):

dp3/common/utils.py

@@ -1,6 +1,7 @@
 """
 auxiliary/utility functions and classes
 """
+
 import datetime
 import re
 from typing import Union

dp3/core/collector.py

@@ -1,6 +1,7 @@
 """
 Core module performing deletion of entities based on specified policy.
 """
+
 import logging
 from collections import defaultdict
 from datetime import datetime, timedelta

dp3/core/link_manager.py

@@ -1,6 +1,7 @@
 """
 Core module managing links between entities.
 """
+
 import logging
 from datetime import datetime, timedelta
 from functools import partial

dp3/history_management/history_manager.py

@@ -411,7 +411,8 @@ def compress_file(original: Path, compressed: Path = None):
     if compressed is None:
         compressed = original.parent / (original.name + ".gz")
 
-    with open(original, encoding="utf-8") as in_fp, gzip.open(
-        compressed, "wt", encoding="utf-8"
-    ) as out_fp:
+    with (
+        open(original, encoding="utf-8") as in_fp,
+        gzip.open(compressed, "wt", encoding="utf-8") as out_fp,
+    ):
         out_fp.writelines(in_fp)

dp3/snapshots/snapshooter.py

@@ -16,6 +16,7 @@
     - Callbacks for data correlation and fusion should happen here
     - Save the complete results into database as snapshots
 """
+
 import logging
 from collections import defaultdict
 from datetime import datetime

dp3/snapshots/snapshot_hooks.py

@@ -1,6 +1,7 @@
 """
 Module managing registered hooks and their dependencies on one another.
 """
+
 import logging
 from collections import defaultdict
 from collections.abc import Hashable

tests/test_common/test_snapshots.py

@@ -123,8 +123,7 @@ def get_master_record(self, etype: str, eid: str, projection=None) -> dict:
 
     def register_on_entity_delete(
         self, f_one: Callable[[str, str], None], f_many: Callable[[str, list[str]], None]
-    ):
-        ...
+    ): ...
 
     def get_module_cache(self, override_called_id: Optional[str] = None):
         return self.module_cache
@@ -146,20 +145,17 @@ def put_task(self, task: Task, priority: bool = False):
 
 
 class MockTaskQueueReader:
-    def ack(self, msg_tag):
-        ...
+    def ack(self, msg_tag): ...
 
 
 class MockCollection(dict):
-    def create_index(self, *args, **kwargs):
-        ...
+    def create_index(self, *args, **kwargs): ...
 
 
 class MockTaskExecutor:
     elog = DummyEventGroup()
 
-    def register_attr_hook(self, *args, **kwargs):
-        ...
+    def register_attr_hook(self, *args, **kwargs): ...
 
 
 class TestSnapshotOperation(unittest.TestCase):