Dispatch an event to the stream if it exists. Tradier can run in polling mode and/or with `connect_stream=False`. Order submission and pollin

Map LumiBot's tradable option expiry to the value expected by ThetaData endpoints.

Ensure ThetaTerminal is running and responsive.

Configure framework-managed daily cash financing for backtests. Parameters ---------- enabled : bool Enables/disa

Create an option symbol string from its components. Parameters ---------- stock_symbol : str The stock symbol, e.g., 'AAPL'.

Check if the DataFrame is empty (compatible with both pandas and polars)

Get bars for an asset by delegating to get_historical_prices_between_dates for fetching the historical data, followed by additional p

Normalise arbitrary option-chain payloads into the standard structure.

Convert an internal LumiBot symbol to a broker-native class-share symbol format. Non class-share symbols are returned unchanged (uppercased/

Parse the given symbol and determine if it's an option or a stock. For options, extract and return the stock symbol, expiration date (as a da

Set the global log level for all Lumibot loggers. Parameters ---------- level : str The log level to set ('DEBUG', 'INFO

Check if a contract symbol matches the given root symbol. Parameters ---------- symbol : str Contract symbol to check

Return a minimal dictionary representation of the asset for progress logging. This creates a lightweight representation suitable for

Return True when a cached dataset satisfies the requested coverage window. IMPORTANT: `prefetch_complete` is a performance optimization flag

Detect status changes and dispatch appropriate events. This method acquires ``_order_update_lock`` to serialize concurrent websocket

Extract error code, message, and details from log record.

OCO orders have empty values for many fields. This function will pull the value from the child order if the value is empty in the par

Lazily initialize and return the option client.

Build a `Data(timestep='day')` object from `(timestamp_str, close)` pairs. All OHLC columns are filled with the provided close to keep the fixtur

Normalize an internal symbol into this broker's preferred native format.

Helper to set the mock time.

Normalize input (datetime or ISO string) to a UTC ISO formatted string. - If input is a string it accepts ISO formats with or without trailin

Aggregate to a new timeframe. Accepts flexible minute/hour/day aliases (e.g. '5min', '5MINUTE', '5 m', '5 Minutes'). Ensures the da

Append placeholder rows for dates that returned no data.

This function is called every polling_interval for OAuth-only configurations. It checks for new orders and dispatches them to the str

Get the parameters of the strategy. Returns ------- parameters : dict The parameters of the strategy.

Not applicable with Crypto 24/7 markets. Returns ------- None

Check if the order is a parent order. Parent orders are typically Multileg orders where the child orders do the actual trading and ca

Limit order logic.

Stop order logic.

Returns a datetime localized to the data source's default timezone. Parameters ---------- dt : datetime.datetime

Return a minimal dictionary representation of the position for progress logging. This creates a lightweight representation suitable

Best-effort update of queue diagnostics for the active download. Called from the queue client while a ThetaData fetch is in progress. It inte