Merge pull request #1558 from andrewwhitehead/fix/sleep

swcurran · web-flow · commit ed4c1fbe87d8 · 2021-12-13T14:36:48.000-08:00
Await asyncio.sleeps
diff --git a/aries_cloudagent/protocols/discovery/v1_0/manager.py b/aries_cloudagent/protocols/discovery/v1_0/manager.py
@@ -133,7 +133,7 @@ async def check_if_disclosure_received(
                 )
             if ex_rec.disclose:
                 return ex_rec
-            asyncio.sleep(0.5)
+            await asyncio.sleep(0.5)
 
     async def create_and_send_query(
         self, query: str, comment: str = None, connection_id: str = None
diff --git a/aries_cloudagent/protocols/discovery/v2_0/manager.py b/aries_cloudagent/protocols/discovery/v2_0/manager.py
@@ -192,7 +192,7 @@ async def check_if_disclosure_received(
                 )
             if ex_rec.disclosures:
                 return ex_rec
-            asyncio.sleep(0.5)
+            await asyncio.sleep(0.5)
 
     async def create_and_send_query(
         self,
diff --git a/aries_cloudagent/protocols/out_of_band/v1_0/manager.py b/aries_cloudagent/protocols/out_of_band/v1_0/manager.py
@@ -928,7 +928,7 @@ async def conn_rec_is_active(self, conn_rec_id: str) -> ConnRecord:
                 conn_rec = await ConnRecord.retrieve_by_id(session, conn_rec_id)
                 if conn_rec.is_ready:
                     return conn_rec
-            asyncio.sleep(0.5)
+            await asyncio.sleep(0.5)
 
     async def create_handshake_reuse_message(
         self,

Original file line number	Diff line number	Diff line change
`@@ -133,7 +133,7 @@ async def check_if_disclosure_received(`
`133`	`133`	`)`
`134`	`134`	`if ex_rec.disclose:`
`135`	`135`	`return ex_rec`
`136`		`- asyncio.sleep(0.5)`
	`136`	`+ await asyncio.sleep(0.5)`
`137`	`137`
`138`	`138`	`async def create_and_send_query(`
`139`	`139`	`self, query: str, comment: str = None, connection_id: str = None`
Original file line number	Diff line number	Diff line change
`@@ -192,7 +192,7 @@ async def check_if_disclosure_received(`
`192`	`192`	`)`
`193`	`193`	`if ex_rec.disclosures:`
`194`	`194`	`return ex_rec`
`195`		`- asyncio.sleep(0.5)`
	`195`	`+ await asyncio.sleep(0.5)`
`196`	`196`
`197`	`197`	`async def create_and_send_query(`
`198`	`198`	`self,`