http connector session workaround
@@ -12,7 +12,8 @@ class HTTPConnector:
self.service_name = service_name
async def send(self, payload: Dict, callback: Callable):
- async with self.session.post(self.url, json=self.formatter([payload])) as resp:
+ async with aiohttp.ClientSession() as session:
+ async with session.post(self.url, json=self.formatter([payload])) as resp:
response = await resp.json()
response_time = time.time()
await callback(
