From f692c0819ca4201c805a37ab0532a7d2191f8ead Mon Sep 17 00:00:00 2001 From: Nawaz Haider Date: Sat, 3 Jan 2026 22:13:26 +0600 Subject: [PATCH 1/2] Refactor hedge order placement logic in place_anchor_and_hedge function for improved clarity and efficiency --- utils/clob_orders.py | 23 ++++++++++------------- 1 file changed, 10 insertions(+), 13 deletions(-) diff --git a/utils/clob_orders.py b/utils/clob_orders.py index 189d838..ea9dadf 100644 --- a/utils/clob_orders.py +++ b/utils/clob_orders.py @@ -36,21 +36,18 @@ async def place_anchor_and_hedge( anchor_token_id = down_token_id hedge_token_id = up_token_id - anchor_order_id = await place_limit_order(anchor_token_id, price, size, expire=True) + anchor_order_id = await place_limit_order(anchor_token_id, price, size) if PLACE_OPPOSITE_ORDER and anchor_order_id: - num_iter = int(66 * (1 / 0.02)) - for _ in range(num_iter): - if in_memory_db_contains_item(anchor_order_id): - hedge_order_id = await place_limit_order( - hedge_token_id, 1 - price - PROFIT_MARGIN, size - ) - logger.info( - f"Order prices: {round(price, 2)} and {round(1 - price - PROFIT_MARGIN, 2)}" - ) - break - await asyncio.sleep(0.02) + hedge_order_id = await place_limit_order( + hedge_token_id, 1 - price - PROFIT_MARGIN, size + ) + if hedge_order_id: + logger.info( + f"Order prices: {round(price, 2)} and {round(1 - price - PROFIT_MARGIN, 2)}" + ) + else: + logger.info("Failed to place hedge order, decrementing trade counter") else: - logger.info(f"Order price: {price} [Canceled before hedge placement]") decrement_trades() From 06527f6bccff744cad1be48a759a22b6dc747378 Mon Sep 17 00:00:00 2001 From: Nawaz Haider Date: Sat, 3 Jan 2026 22:27:15 +0600 Subject: [PATCH 2/2] Refactor order placement logic in place_anchor_and_hedge function for improved clarity and efficiency --- utils/clob_orders.py | 20 +++++++------------- 1 file changed, 7 insertions(+), 13 deletions(-) diff --git a/utils/clob_orders.py b/utils/clob_orders.py index ea9dadf..0b6da75 100644 --- a/utils/clob_orders.py +++ b/utils/clob_orders.py @@ -36,19 +36,13 @@ async def place_anchor_and_hedge( anchor_token_id = down_token_id hedge_token_id = up_token_id - anchor_order_id = await place_limit_order(anchor_token_id, price, size) - if PLACE_OPPOSITE_ORDER and anchor_order_id: - hedge_order_id = await place_limit_order( - hedge_token_id, 1 - price - PROFIT_MARGIN, size - ) - if hedge_order_id: - logger.info( - f"Order prices: {round(price, 2)} and {round(1 - price - PROFIT_MARGIN, 2)}" - ) - else: - logger.info("Failed to place hedge order, decrementing trade counter") - else: - decrement_trades() + asyncio.create_task(place_limit_order(anchor_token_id, price, size)) + asyncio.create_task( + place_limit_order(hedge_token_id, 1 - price - PROFIT_MARGIN, size) + ) + logger.info( + f"Placed anchor and hedge orders: Anchor Token ID={anchor_token_id}, Hedge Token ID={hedge_token_id}" + ) async def place_limit_order(token_id: str, price: float, size: int, expire=False):