Bump black from 21.10b0 to 24.4.2

baseplate/__init__.py

@@ -157,7 +157,7 @@ def from_upstream(
             raise ValueError("invalid sampled value")
 
         if flags is not None:
-            if not 0 <= flags < 2 ** 64:
+            if not 0 <= flags < 2**64:
                 raise ValueError("invalid flags value")
 
         return cls(trace_id, parent_id, span_id, sampled, flags)

baseplate/clients/__init__.py

@@ -5,6 +5,7 @@
 trace information is passed on and metrics are collected automatically.
 
 """
+
 from typing import Any
 from typing import TYPE_CHECKING
 

baseplate/clients/cassandra.py

@@ -364,14 +364,16 @@ def execute_async(
         **kwargs: Any,
     ) -> ResponseFuture:
         prom_labels = CassandraPrometheusLabels(
-            cassandra_client_name=self.prometheus_client_name
-            if self.prometheus_client_name is not None
-            else self.context_name,
+            cassandra_client_name=(
+                self.prometheus_client_name
+                if self.prometheus_client_name is not None
+                else self.context_name
+            ),
             cassandra_keyspace=self.session.keyspace,
             cassandra_query_name=query_name if query_name is not None else "",
-            cassandra_cluster_name=self.prometheus_cluster_name
-            if self.prometheus_cluster_name is not None
-            else "",
+            cassandra_cluster_name=(
+                self.prometheus_cluster_name if self.prometheus_cluster_name is not None else ""
+            ),
         )
 
         REQUEST_ACTIVE.labels(**prom_labels._asdict()).inc()

baseplate/clients/memcache/lib.py

@@ -10,6 +10,7 @@
 should use pickle_and_compress() and decompress_and_unpickle().
 
 """
+
 import json
 import logging
 import pickle

baseplate/lib/__init__.py

@@ -1,4 +1,5 @@
 """Internal library helpers."""
+
 import functools
 import inspect
 import warnings

baseplate/lib/_requests.py

@@ -3,6 +3,7 @@
 This stuff is not stable yet, so it's only for baseplate-internal use.
 
 """
+
 import socket
 import urllib.parse
 

baseplate/lib/config.py

@@ -453,8 +453,7 @@ def __init__(self) -> None:
         super().__init__()
         self.__dict__ = self
 
-    def __getattr__(self, name: str) -> Any:
-        ...
+    def __getattr__(self, name: str) -> Any: ...
 
 
 ConfigSpecItem = Union["Parser", Dict[str, Any], Callable[[str], T]]

baseplate/lib/crypto.py

@@ -29,6 +29,7 @@
 
 
 """
+
 import base64
 import binascii
 import datetime

baseplate/lib/datetime.py

@@ -1,4 +1,5 @@
 """Extensions to the standard library `datetime` module."""
+
 from datetime import datetime
 from datetime import timezone
 

baseplate/lib/events.py

@@ -9,6 +9,7 @@
 by a separate daemon.
 
 """
+
 import logging
 
 from typing import Any

baseplate/lib/file_watcher.py

@@ -34,6 +34,7 @@
 would change whenever the underlying file changes.
 
 """
+
 import logging
 import os
 import typing

baseplate/lib/live_data/writer.py

@@ -1,4 +1,5 @@
 """Write a file's contents to a node in ZooKeeper."""
+
 import argparse
 import configparser
 import difflib

baseplate/lib/live_data/zookeeper.py

@@ -1,4 +1,5 @@
 """Helpers for interacting with ZooKeeper."""
+
 from typing import Optional
 
 from kazoo.client import KazooClient

baseplate/lib/message_queue.py

@@ -1,4 +1,5 @@
 """A Gevent-friendly POSIX message queue."""
+
 import select
 
 from typing import Optional

baseplate/lib/metrics.py

@@ -42,6 +42,7 @@
 .. _StatsD: https://github.com/statsd/statsd
 
 """
+
 import collections
 import errno
 import logging

baseplate/lib/prometheus_metrics.py

@@ -32,7 +32,7 @@
 default_size_factor = 2
 default_size_count = 20
 default_size_buckets = [
-    default_size_start * default_size_factor ** i for i in range(default_size_count)
+    default_size_start * default_size_factor**i for i in range(default_size_count)
 ]
 
 

baseplate/lib/random.py

@@ -1,4 +1,5 @@
 """Extensions to the standard library `random` module."""
+
 import bisect
 import random
 import typing

baseplate/lib/retry.py

@@ -1,4 +1,5 @@
 """Policies for retrying an operation safely."""
+
 import time
 
 from typing import Iterator

baseplate/lib/secrets.py

@@ -1,4 +1,5 @@
 """Application integration with the secret fetcher daemon."""
+
 import base64
 import binascii
 import json
@@ -121,8 +122,7 @@ def _decode_secret(path: str, encoding: str, value: str) -> bytes:
 
 
 class SecretParser(Protocol):
-    def __call__(self, data: Dict[str, Any], secret_path: str = "") -> Dict[str, str]:
-        ...
+    def __call__(self, data: Dict[str, Any], secret_path: str = "") -> Dict[str, str]: ...
 
 
 def parse_secrets_fetcher(data: Dict[str, Any], secret_path: str = "") -> Dict[str, str]:

baseplate/lib/service_discovery.py

@@ -17,6 +17,7 @@
     print(backend.endpoint.address)
 
 """
+
 import json
 
 from typing import IO

baseplate/lib/thrift_pool.py

@@ -14,6 +14,7 @@
         client.do_example_thing()
 
 """
+
 import contextlib
 import logging
 import queue

baseplate/observers/tracing.py

@@ -1,4 +1,5 @@
 """Components for processing Baseplate spans for service request tracing."""
+
 import collections
 import json
 import logging

baseplate/server/__init__.py

@@ -2,6 +2,7 @@
 
 This command serves your application from the given configuration file.
 """
+
 from __future__ import annotations
 
 import argparse

baseplate/server/einhorn.py

@@ -1,4 +1,5 @@
 """Client library for children of Einhorn."""
+
 import contextlib
 import json
 import os

baseplate/server/healthcheck.py

@@ -1,4 +1,5 @@
 """Check health of a baseplate service on localhost."""
+
 import argparse
 import socket
 import sys

baseplate/server/prometheus.py

@@ -10,6 +10,7 @@
 can aggregate and serve metrics for all workers.
 
 """
+
 import atexit
 import logging
 import os

baseplate/server/reloader.py

@@ -5,6 +5,7 @@
 settings.
 
 """
+
 import logging
 import os
 import re

baseplate/sidecars/event_publisher.py

@@ -105,9 +105,9 @@ def __init__(self, metrics_client: metrics.Client, cfg: Any):
         self.key_name = cfg.key.name
         self.key_secret = cfg.key.secret
         self.session = requests.Session()
-        self.session.headers[
-            "User-Agent"
-        ] = f"baseplate.py-{self.__class__.__name__}/{baseplate_version}"
+        self.session.headers["User-Agent"] = (
+            f"baseplate.py-{self.__class__.__name__}/{baseplate_version}"
+        )
 
     def _sign_payload(self, payload: bytes) -> str:
         digest = hmac.new(self.key_secret, payload, hashlib.sha256).hexdigest()

baseplate/sidecars/live_data_watcher.py

@@ -1,4 +1,5 @@
 """Watch nodes in ZooKeeper and sync their contents to disk on change."""
+
 import argparse
 import configparser
 import json

baseplate/sidecars/secrets_fetcher.py

@@ -60,6 +60,7 @@
 write to a new file in whatever format needed, and restart other services if necessary.
 
 """
+
 import argparse
 import configparser
 import datetime
@@ -155,9 +156,9 @@ def __init__(self, base_url: str, role: str, auth_type: Authenticator, mount_poi
         self.auth_type = auth_type
         self.mount_point = mount_point
         self.session = requests.Session()
-        self.session.headers[
-            "User-Agent"
-        ] = f"baseplate.py-{self.__class__.__name__}/{baseplate_version}"
+        self.session.headers["User-Agent"] = (
+            f"baseplate.py-{self.__class__.__name__}/{baseplate_version}"
+        )
         self.client: Optional["VaultClient"] = None
 
     def _make_client(self) -> "VaultClient":

baseplate/sidecars/trace_publisher.py

@@ -62,9 +62,9 @@ def __init__(
         adapter = requests.adapters.HTTPAdapter(pool_connections=num_conns, pool_maxsize=num_conns)
         parsed_url = urllib.parse.urlparse(zipkin_api_url)
         self.session = requests.Session()
-        self.session.headers[
-            "User-Agent"
-        ] = f"baseplate.py-{self.__class__.__name__}/{baseplate_version}"
+        self.session.headers["User-Agent"] = (
+            f"baseplate.py-{self.__class__.__name__}/{baseplate_version}"
+        )
         self.session.mount(f"{parsed_url.scheme}://", adapter)
         self.endpoint = f"{zipkin_api_url}/spans"
         self.metrics = metrics_client

docs/tutorial/chapter3/helloworld.py

@@ -1,5 +1,6 @@
 from baseplate import Baseplate
 from baseplate.frameworks.pyramid import BaseplateConfigurator
+
 from pyramid.config import Configurator
 from pyramid.view import view_config
 

docs/tutorial/chapter4/helloworld.py

@@ -1,6 +1,7 @@
 from baseplate import Baseplate
 from baseplate.clients.sqlalchemy import SQLAlchemySession
 from baseplate.frameworks.pyramid import BaseplateConfigurator
+
 from pyramid.config import Configurator
 from pyramid.view import view_config