Skip to content

Commit

Permalink
Fix issues pointed out by utility "black"
Browse files Browse the repository at this point in the history
  • Loading branch information
srp3rd committed May 22, 2024
1 parent bdf8e78 commit e9dcc99
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 3 deletions.
3 changes: 1 addition & 2 deletions python/lsst/ctrl/oods/msgQueue.py
Original file line number Diff line number Diff line change
Expand Up @@ -57,8 +57,7 @@ def __init__(self, brokers, group_id, topics, max_messages):
self.createConsumer(config, topics)

def createConsumer(self, config, topics):
"""Create a Kafka Consumer
"""
"""Create a Kafka Consumer"""
self.consumer = Consumer(config)
self.consumer.subscribe(topics)

Expand Down
2 changes: 1 addition & 1 deletion tests/test_msg.py
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,7 @@ async def testAuxTelIngest(self):
"""test ingesting an auxtel file"""
test_dir = os.path.abspath(os.path.dirname(__file__))
msg_file = os.path.join(test_dir, "data", "kafka_msg.json")
with open(msg_file, 'r') as f:
with open(msg_file, "r") as f:
message = f.read()

fits_name = "2020032700020-det000.fits.fz"
Expand Down

0 comments on commit e9dcc99

Please sign in to comment.