Skip to content

Commit 23ac757

Browse files
[pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
1 parent 9ff53aa commit 23ac757

File tree

3 files changed

+6
-5
lines changed

3 files changed

+6
-5
lines changed

src/decisionengine/framework/about.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,8 @@
22
# SPDX-License-Identifier: Apache-2.0
33

44
"""
5-
PEP-0396 provides instructions for providing module versions
6-
While we are at it, add a few other useful bits
5+
PEP-0396 provides instructions for providing module versions
6+
While we are at it, add a few other useful bits
77
"""
88
try:
99
# This is built by setuptools_scm

src/decisionengine/framework/dataspace/datasources/sqlalchemy_ds/utils.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
# SPDX-License-Identifier: Apache-2.0
33

44
"""
5-
Code not written by us
5+
Code not written by us
66
"""
77
import os
88

src/decisionengine/framework/taskmanager/LatestMessages.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,8 +70,9 @@ def receive(body, message):
7070
message.ack()
7171

7272
_cl = Connection(self.broker_url)
73-
with connections[_cl].acquire(block=True) as conn, conn.Consumer(
74-
self.queues, accept=["pickle"], callbacks=[receive]
73+
with (
74+
connections[_cl].acquire(block=True) as conn,
75+
conn.Consumer(self.queues, accept=["pickle"], callbacks=[receive]),
7576
):
7677
self._listening.set()
7778
while not self._stop.is_set():

0 commit comments

Comments
 (0)