diff --git a/aries_cloudagent/protocols/didexchange/v1_0/manager.py b/aries_cloudagent/protocols/didexchange/v1_0/manager.py
index 8489cd4964..c7c9e51eaa 100644
--- a/aries_cloudagent/protocols/didexchange/v1_0/manager.py
+++ b/aries_cloudagent/protocols/didexchange/v1_0/manager.py
@@ -705,7 +705,8 @@ async def accept_response(
             async with self.profile.session() as session:
                 try:
                     conn_rec = await ConnRecord.retrieve_by_request_id(
-                        session, response._thread_id,
+                        session,
+                        response._thread_id,
                         their_role=ConnRecord.Role.RESPONDER.rfc23,
                     )
                 except StorageNotFoundError:
@@ -713,7 +714,8 @@ async def accept_response(
                 if not conn_rec:
                     try:
                         conn_rec = await ConnRecord.retrieve_by_request_id(
-                            session, response._thread_id,
+                            session,
+                            response._thread_id,
                             their_role=ConnRecord.Role.RESPONDER.rfc160,
                         )
                     except StorageNotFoundError:
@@ -821,7 +823,8 @@ async def accept_complete(
         async with self.profile.session() as session:
             try:
                 conn_rec = await ConnRecord.retrieve_by_request_id(
-                    session, complete._thread_id,
+                    session,
+                    complete._thread_id,
                     their_role=ConnRecord.Role.REQUESTER.rfc23,
                 )
             except StorageNotFoundError:
@@ -830,7 +833,8 @@ async def accept_complete(
             if not conn_rec:
                 try:
                     conn_rec = await ConnRecord.retrieve_by_request_id(
-                        session, complete._thread_id,
+                        session,
+                        complete._thread_id,
                         their_role=ConnRecord.Role.REQUESTER.rfc160,
                     )
                 except StorageNotFoundError: