Institutional Execution & Profit Realization Architecture

Following our rigorous profit audit (confirming ₹0.00 discrepancy to the paisa) and an in-depth analysis of institutional order flow mechanics versus retail trading habits, two critical enhancements have been designed, coded, rigorously tested, and successfully deployed to the AWS EC2 production server:

A core question asked was: "Is the system waiting for candle close or taking trades in between? Which one is better? How do institutions work?"

In high-velocity option buying, option delta and gamma surge parabolically during the climax of a directional expansion (e.g., a breakout into deep out-of-the-money or an intraday trend squeeze). While our trailing stop engine previously used an 80%–85% peak profit retention ratchet, a runner that achieved +8.0R or +10.0R could still give back 15%–20% of its peak before the trailing stop triggered.

The Institutional Fix: When price hits a statistical expansion ceiling (where institutional liquidity is liquidating into FOMO buyers), the system executes a Terminal Blow-off Harvest, booking 100% of the remaining runner at maximum extension.

# runner_engine.py — Step 0: Terminal Blow-off Expansion Harvest
risk_per_unit = trade.option_entry - trade.initial_stop
current_r = (current_option_price - trade.option_entry) / risk_per_unit if risk_per_unit > 1e-4 else 0.0

profile = getattr(trade, "scaling_profile", ScalingProfile.STANDARD_BALANCED)
if profile == ScalingProfile.EXPIRY_GAMMA:
    terminal_r = self.terminal_target_r_gamma
elif profile == ScalingProfile.TREND_RUNNER:
    terminal_r = self.terminal_target_r_trend
elif profile == ScalingProfile.QUICK_HARVEST:
    terminal_r = self.terminal_target_r_quick
else:
    terminal_r = self.terminal_target_r_standard

if terminal_r > 0.0 and current_r >= terminal_r:
    return RunnerEvaluationResult(
        should_exit=True,
        exit_reason=ExitReason.TARGET_REACHED,
        new_option_stop=current_option_price,
        new_underlying_stop=None,
        stop_updated=False,
        rationale=(
            f"Terminal blow-off target reached (+{current_r:.1f}R >= +{terminal_r:.1f}R objective "
            f"for {profile.value} profile); 100% position harvested at maximum expansion"
        ),
    )

In Indian equity derivatives (NSE F&O), option contracts must be transacted in discrete lot sizes (e.g. 1 lot = 25 or 65 shares). Fractional lot exits (such as booking 40% of 1 lot = 10 shares) are prohibited by exchange mechanics.

Previously, when a user traded a 1-lot position, _calculate_partial_qty returned 0 at Milestone 1 (+1.5R) and Milestone 2 (+2.5R/+3.0R) to protect the position from being illegally fragmented. While the stop loss was moved to breakeven, in choppy or range-bound markets, the entire 1-lot position would eventually retrace back to breakeven or trailing stop, booking 0 partial profits.

The Institutional Fix: We introduced a lot-aware profit realization policy:

# trade_manager.py — _process_milestone_2 (Single-Lot Policy for Quick Harvest)
is_single_lot = self.enforce_exchange_lots and (trade.lots <= 1 or trade.current_quantity <= self.lot_size)

if is_single_lot and self.enable_single_lot_target_exit and m3_pct <= 0.0:
    up = underlying_price or trade.nifty_entry
    rat = (
        f"Single-lot position reached target objective (+{m2_r:.1f}R) in {profile.value} profile; "
        f"100% position harvested at target"
    )
    closed_events = self.close_trade(
        exit_price=option_ltp,
        underlying_price=up,
        exit_reason=ExitReason.TARGET_REACHED,
        timestamp=timestamp,
        rationale=rat,
    )
    events.extend(closed_events)
    return events

Below is a direct comparison between the old system behavior and the enhanced institutional architecture across two standard market days:

Every code modification was backed by comprehensive unit tests and verified both locally and on the production cloud infrastructure:

# Deployment Commands Executed:
scp -i nifty-key.pem nifty_expansion_runner/trade_management/runner_engine.py ubuntu@13.207.146.76:/home/ubuntu/AntigravityTradeSetup/nifty_expansion_runner/trade_management/
scp -i nifty-key.pem nifty_expansion_runner/trade_management/trade_manager.py ubuntu@13.207.146.76:/home/ubuntu/AntigravityTradeSetup/nifty_expansion_runner/trade_management/
scp -i nifty-key.pem tests/unit/test_trade_manager.py ubuntu@13.207.146.76:/home/ubuntu/AntigravityTradeSetup/tests/unit/

# Systemd Restart & Verification:
sudo systemctl restart nifty-runner.service
curl -s http://localhost:8080/api/health
# Response:
# {"status": "HEALTHY", "is_feed_stale": false, "data_freshness_seconds": 1.72, "mode": "PAPER"}