IS-1241: aio-pika update

iconservice/icon_inner_service.py

@@ -15,7 +15,7 @@
 import asyncio
 import json
 from concurrent.futures.thread import ThreadPoolExecutor
-from typing import Any, TYPE_CHECKING
+from typing import Any, TYPE_CHECKING, Optional
 
 from earlgrey import message_queue_task, MessageQueueStub, MessageQueueService
 
@@ -448,7 +448,7 @@ def make_error_response(code: Any, message: str) -> dict:
 class IconScoreInnerService(MessageQueueService[IconScoreInnerTask]):
  TaskType = IconScoreInnerTask
 
- def _callback_connection_close(self, exc: Exception):
+ def _callback_connection_close(self, sender, exc: Optional[BaseException], *args, **kwargs):
  Logger.error(tag=_TAG, msg=f"[Inner Service] connection closed. {exc}")
  self.clean_close()
 
@@ -460,5 +460,5 @@ def clean_close(self):
 class IconScoreInnerStub(MessageQueueStub[IconScoreInnerTask]):
  TaskType = IconScoreInnerTask
 
- def _callback_connection_close(self, exc: Exception):
+ def _callback_connection_close(self, sender, exc: Optional[BaseException], *args, **kwargs):
  Logger.error(tag=_TAG, msg=f"[Inner Stub] connection closed. {exc}")

requirements.txt

@@ -1,7 +1,7 @@
 setproctitle~=1.1.10
 plyvel~=1.2.0
 coincurve~=13.0.0
-earlgrey~=0.1.1
+earlgrey~=0.2.0
 iconcommons~=1.1.3
 msgpack~=1.0.0
 iso3166~=1.0.1