fix

src/chtools/chadmin/cli/chs3_backup_group.py

@@ -67,9 +67,7 @@ def cleanup_backups(ctx, dry_run, keep_going):
     )
 
 
-def delete_chs3_backups(
-    ctx, chs3_backups, *, keep_going=False, dry_run=False
-):
+def delete_chs3_backups(ctx, chs3_backups, *, keep_going=False, dry_run=False):
     """
     Delete CHS3 backups.
     """

src/chtools/chadmin/cli/object_storage_group.py

@@ -4,7 +4,7 @@
 import sys
 from datetime import datetime, timedelta, timezone
 from gzip import GzipFile
-from io import TextIOWrapper, IOBase
+from io import IOBase, TextIOWrapper
 from pathlib import Path
 from typing import Dict, Iterator, List, Optional, Union
 
@@ -173,7 +173,7 @@ def list_objects(
     help="Input stream is compressed using GZIP format",
 )
 @pass_context
-def clean_object_storage(ctx , file , compressed ):
+def clean_object_storage(ctx, file, compressed):
     disk_conf: S3DiskConfiguration = ctx.obj["disk_configuration"]
 
     if compressed:
@@ -189,9 +189,7 @@ def clean_object_storage(ctx , file , compressed ):
 
 
 @contextlib.contextmanager
-def dump_writer(
-    compressed, file_path = None
-):
+def dump_writer(compressed, file_path=None):
     writer = open(file_path, "wb") if file_path is not None else sys.stdout.buffer
     try:
         yield GzipFile(mode="wb", fileobj=writer) if compressed else writer

src/chtools/chadmin/internal/diagnostics/data.py

@@ -8,7 +8,7 @@
 import yaml
 from requests.exceptions import RequestException
 
-from chtools.common.clickhouse.client import OutputFormat, ClickhouseClient
+from chtools.common.clickhouse.client import ClickhouseClient, OutputFormat
 
 from .utils import delayed
 
@@ -194,9 +194,7 @@ def _write_result(buffer_, result, format_=None):
 
 
 @delayed
-def add_query(
-    diagnostics, name, client, query, format_, section=None
-):
+def add_query(diagnostics, name, client, query, format_, section=None):
     query_args = {
         "normalize_queries": diagnostics.normalize_queries,
     }