Skip to content

Commit

Permalink
Run all pre-commit hooks for the first time
Browse files Browse the repository at this point in the history
  • Loading branch information
lpsinger committed Aug 5, 2024
1 parent 08244a7 commit 751bf57
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 6 deletions.
5 changes: 2 additions & 3 deletions gcn_classic_to_kafka/cli.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,17 +9,16 @@

import asyncio
import logging
import urllib
import signal
import sys
import urllib

import click
import gcn_kafka
import prometheus_client

from . import heartbeat, metrics
from .socket import client_connected
from . import heartbeat
from . import metrics

log = logging.getLogger(__name__)

Expand Down
1 change: 1 addition & 0 deletions gcn_classic_to_kafka/metrics.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@
# SPDX-License-Identifier: Apache-2.0
#
"""Prometheus metrics."""

import prometheus_client

connected = prometheus_client.Gauge(
Expand Down
4 changes: 2 additions & 2 deletions gcn_classic_to_kafka/socket.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@
# SPDX-License-Identifier: Apache-2.0
#
"""Protocol handler for GCN socket connection."""

import asyncio
import logging
import struct
Expand All @@ -14,8 +15,8 @@
import gcn
import lxml.etree

from .common import notice_type_int_to_str, topic_for_notice_type_str
from . import metrics
from .common import notice_type_int_to_str, topic_for_notice_type_str

log = logging.getLogger(__name__)

Expand All @@ -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
):
Expand Down
2 changes: 1 addition & 1 deletion gcn_classic_to_kafka/test/test_socket.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,8 @@
# SPDX-License-Identifier: Apache-2.0
#
import asyncio
from unittest import mock
import struct
from unittest import mock

import gcn
import pytest
Expand Down

0 comments on commit 751bf57

Please sign in to comment.