diff --git a/brokers/base_broker.py b/brokers/base_broker.py
index 8a4eeb56..dd5c24cb 100644
--- a/brokers/base_broker.py
+++ b/brokers/base_broker.py
@@ -497,7 +497,7 @@ async def cancel_order(self, order_id):
                 trade = await session.execute(session.query(Trade).filter_by(id=order_id))
                 trade = trade.scalars().first()
                 if trade:
-                    await self.update_trade(session, trade.id, cancel_status)
+                    await self.update_trade(session, trade.id, 'cancelled')
             logger.info(
                 'Order cancelled successfully', extra={
                     'cancel_status': cancel_status})