diff --git a/onchain/pools/solana/orca_protocol.py b/onchain/pools/solana/orca_protocol.py
index a71193f..9fd5933 100644
--- a/onchain/pools/solana/orca_protocol.py
+++ b/onchain/pools/solana/orca_protocol.py
@@ -40,6 +40,12 @@ async def session(self) -> aiohttp.ClientSession:
             self._session = aiohttp.ClientSession()
         return self._session
 
+    async def close(self):
+        """Close the protocol's session."""
+        if self._session:
+            await self._session.close()
+            self._session = None
+
     async def get_pools(self, token_metadata_repo: TokenMetadataRepo) -> List[Pool]:
         """
         Fetch pools from Orca API and convert to the internal Pool model