From 439a9cd3d8ca3f55ef432eff4e2d596af8e7f6bb Mon Sep 17 00:00:00 2001 From: Leo Singer Date: Fri, 2 Aug 2024 10:52:26 -0400 Subject: [PATCH] Run all pre-commit hooks for the first time --- gcn_classic_to_kafka/metrics.py | 1 + gcn_classic_to_kafka/socket.py | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/gcn_classic_to_kafka/metrics.py b/gcn_classic_to_kafka/metrics.py index 759becb..692a8d6 100644 --- a/gcn_classic_to_kafka/metrics.py +++ b/gcn_classic_to_kafka/metrics.py @@ -6,6 +6,7 @@ # SPDX-License-Identifier: Apache-2.0 # """Prometheus metrics.""" + import prometheus_client connected = prometheus_client.Gauge( diff --git a/gcn_classic_to_kafka/socket.py b/gcn_classic_to_kafka/socket.py index 0731355..2035b5b 100644 --- a/gcn_classic_to_kafka/socket.py +++ b/gcn_classic_to_kafka/socket.py @@ -6,6 +6,7 @@ # SPDX-License-Identifier: Apache-2.0 # """Protocol handler for GCN socket connection.""" + import asyncio import logging import struct @@ -29,7 +30,6 @@ def client_connected(producer: confluent_kafka.Producer, timeout: float = 90): - async def client_connected_cb( reader: asyncio.StreamReader, writer: asyncio.StreamWriter ):