Merge pull request #196 from BoostryJP/fix/#194

fix: Add error handling when quorum terminating

Author: YoshihitoAso

app/utils/web3_utils.py

@@ -20,6 +20,7 @@
 import threading
 from typing import Any
 import time
+from json.decoder import JSONDecodeError
 
 from sqlalchemy import create_engine
 from sqlalchemy.orm import Session
@@ -111,7 +112,8 @@ def make_request(self, method: RPCEndpoint, params: Any) -> RPCResponse:
                     # Call RPC method
                     try:
                         return super().make_request(method, params)
-                    except ConnectionError:
+                    except (ConnectionError, JSONDecodeError):
+                        # NOTE: JSONDecodeError occurs when a request is sent during the termination process of Quorum.
                         counter += 1
                         if counter <= WEB3_REQUEST_RETRY_COUNT:
                             time.sleep(WEB3_REQUEST_WAIT_TIME)

requirements.txt

@@ -12,4 +12,5 @@ boto3==1.17.12
 alembic==1.5.6
 PyMySQL==1.0.2
 pytz==2021.1
-shared-memory-dict==0.5.0
+shared-memory-dict==0.5.0
+requests==2.25.1