Change ipfs log level

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "sw-utils"
-version = "0.3.27"
+version = "0.3.28"
 description = "StakeWise Python utils"
 authors = ["StakeWise Labs <[email protected]>"]
 license = "GPL-3.0-or-later"

sw_utils/consensus.py

@@ -100,7 +100,7 @@ async def submit_voluntary_exit(
 
                 if i == len(self.base_urls) - 1:
                     raise error
-                logger.error('%s: %s', url, repr(error))
+                logger.warning('%s: %s', url, repr(error))
 
     async def get_chain_finalized_head(self, slots_per_epoch: int) -> ChainHead:
         """Fetches the fork safe chain head."""
@@ -172,7 +172,7 @@ async def _async_make_get_request_inner(self, endpoint_uri: str) -> dict[str, An
 
                 if i == len(self.base_urls) - 1:
                     raise error
-                logger.error('%s: %s', url, repr(error))
+                logger.warning('%s: %s', url, repr(error))
 
         return {}
 

sw_utils/execution.py

@@ -89,7 +89,7 @@ async def make_request_inner(self, method: RPCEndpoint, params: Any) -> RPCRespo
                 if i == len(self._providers) - 1:
                     raise error
 
-                logger.error('%s: %s', provider.endpoint_uri, repr(error))
+                logger.warning('%s: %s', provider.endpoint_uri, repr(error))
 
         return {}
 
@@ -121,5 +121,5 @@ def get_execution_client(
 
     if is_poa:
         client.middleware_onion.inject(async_geth_poa_middleware, layer=0)
-        logger.info('Injected POA middleware')
+        logger.debug('Injected POA middleware')
     return client

sw_utils/ipfs.py

@@ -212,7 +212,7 @@ async def _upload(self, coros: list) -> str:
         ipfs_hashes: dict[str, int] = {}
         for value in result:
             if isinstance(value, BaseException):
-                logger.error(repr(value))
+                logger.warning(repr(value))
                 continue
 
             ipfs_hash = _strip_ipfs_prefix(value)
@@ -239,7 +239,7 @@ async def remove(self, ipfs_hash: str) -> None:
         )
         for value in result:
             if isinstance(value, BaseException):
-                logger.error(repr(value))
+                logger.warning(repr(value))
                 continue
         return None
 
@@ -265,7 +265,7 @@ async def fetch_bytes(self, ipfs_hash: str) -> bytes:
 
                 return self._ipfs_fetch_bytes(endpoint, ipfs_hash)
             except Exception as e:
-                logger.error(repr(e))
+                logger.warning(repr(e))
 
         raise IpfsException(f'Failed to fetch IPFS data at {ipfs_hash}')
 
@@ -294,7 +294,7 @@ async def fetch_json(self, ipfs_hash: str) -> Any:
 
                 return self._ipfs_fetch_json(endpoint, ipfs_hash)
             except Exception as e:
-                logger.error(repr(e))
+                logger.warning(repr(e))
 
         raise IpfsException(f'Failed to fetch IPFS data at {ipfs_hash}')