diff --git a/order_listener.py b/order_listener.py index c3df858..54f333a 100644 --- a/order_listener.py +++ b/order_listener.py @@ -26,7 +26,7 @@ async def handle_message(message): data = json.loads(message) logger.debug(f"Received Message: {data}") data_type = data.get("type") - if data_type == "PLACEMENT": + if data_type in ["PLACEMENT", "CANCELLATION"]: return orders_ids = [] orders_ids.append(data.get("id"))