From 08b066b252837a6d821c1fb8741f7b44e020850e Mon Sep 17 00:00:00 2001 From: Brian DeSimone Date: Wed, 14 Apr 2021 18:07:53 -0500 Subject: [PATCH 1/4] adding the event loop to the tcp connector --- stitch_connect_client/rest.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/stitch_connect_client/rest.py b/stitch_connect_client/rest.py index a229522..9828dbb 100644 --- a/stitch_connect_client/rest.py +++ b/stitch_connect_client/rest.py @@ -67,7 +67,9 @@ def __init__(self, configuration, pools_size=4, maxsize=None): ssl_context.check_hostname = False ssl_context.verify_mode = ssl.CERT_NONE - connector = aiohttp.TCPConnector(limit=maxsize, ssl=ssl_context) + loop = asyncio.get_event_loop() + logger.debug(f"The running asyncio loop: {loop}") + connector = aiohttp.TCPConnector(limit=maxsize, ssl=ssl_context, loop=loop) # https pool manager if configuration.proxy: From 35254e1a55bf95ec589bc186e1f762f4db9d1b5b Mon Sep 17 00:00:00 2001 From: Brian DeSimone Date: Wed, 14 Apr 2021 19:16:41 -0500 Subject: [PATCH 2/4] adding print --- stitch_connect_client/rest.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/stitch_connect_client/rest.py b/stitch_connect_client/rest.py index 9828dbb..753bb39 100644 --- a/stitch_connect_client/rest.py +++ b/stitch_connect_client/rest.py @@ -68,7 +68,9 @@ def __init__(self, configuration, pools_size=4, maxsize=None): ssl_context.verify_mode = ssl.CERT_NONE loop = asyncio.get_event_loop() - logger.debug(f"The running asyncio loop: {loop}") + print("\n\n\n\n\n-----------------------------") + print(loop) + print("-----------------------------\n\n\n\n\n") connector = aiohttp.TCPConnector(limit=maxsize, ssl=ssl_context, loop=loop) # https pool manager From 36464ccb0f5eee918587c40cfd22a8d2c737ae35 Mon Sep 17 00:00:00 2001 From: Brian DeSimone Date: Thu, 15 Apr 2021 13:30:28 -0500 Subject: [PATCH 3/4] logs --- stitch_connect_client/rest.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/stitch_connect_client/rest.py b/stitch_connect_client/rest.py index 753bb39..06c9bd0 100644 --- a/stitch_connect_client/rest.py +++ b/stitch_connect_client/rest.py @@ -68,7 +68,7 @@ def __init__(self, configuration, pools_size=4, maxsize=None): ssl_context.verify_mode = ssl.CERT_NONE loop = asyncio.get_event_loop() - print("\n\n\n\n\n-----------------------------") + print("\n\n\n\n\nSTITCH-----------------------------") print(loop) print("-----------------------------\n\n\n\n\n") connector = aiohttp.TCPConnector(limit=maxsize, ssl=ssl_context, loop=loop) From d448820435462d090d620c67f143e4f5f6c2b9ca Mon Sep 17 00:00:00 2001 From: Brian DeSimone Date: Thu, 15 Apr 2021 15:22:51 -0500 Subject: [PATCH 4/4] adding more logs --- stitch_connect_client/rest.py | 1 + 1 file changed, 1 insertion(+) diff --git a/stitch_connect_client/rest.py b/stitch_connect_client/rest.py index 06c9bd0..7389960 100644 --- a/stitch_connect_client/rest.py +++ b/stitch_connect_client/rest.py @@ -70,6 +70,7 @@ def __init__(self, configuration, pools_size=4, maxsize=None): loop = asyncio.get_event_loop() print("\n\n\n\n\nSTITCH-----------------------------") print(loop) + print(asyncio.Task.current_task(loop=loop)) print("-----------------------------\n\n\n\n\n") connector = aiohttp.TCPConnector(limit=maxsize, ssl=ssl_context, loop=loop)