retrieveLiquidations

async def retrieveLiquidations(market_id, price_offset):
    """Retrieve liquidation data for a market with price offset."""
    base_url = os.getenv("API_SERVER_URL")
    async with httpx.AsyncClient() as session:
        client = PerpetualsClient(base_url=base_url, session=session)

        try:
            address = os.getenv("ACCOUNT")

            liquidations = await client.get_liquidation(
                market=market_id, price_offset=int(price_offset)
            )
            return liquidations
        except Exception as e:
            print(f"Error retrieving liquidations: {e}")
            return []