Sends an operational alert to Telegram. Returns True if a message was actually sent, False otherwise (test mode, unconfigured, throttled, or

Publishes a pipeline lifecycle event. Returns True if the event was published, False otherwise (test mode or redis unavailable). Payload

Main function to check the application's status by verifying open positions and active pipelines for any inconsistencies. Notes ----

Compares every active pipeline's recorded units with the actual exchange position and corrects the records (exchange wins) where the mismatch

Delivers a trading signal to the execution service, retrying transport failures with backoff until the delivery deadline. The execution

Returns the moment after which delivering this signal is no longer safe. The deadline is the earlier of: the close of the candle the signal

Places an order, retrying on connection errors without ever placing it twice: the same newClientOrderId is reused across attempts, an

Public method which sets in motion the data pipeline for a given symbol. Returns ------- None

Yields SSE frames from a redis pubsub subscription. Uses get_message(timeout=...) rather than listen(): listen() blocks indefinitely, wh

Public method which stops the data pipeline for the symbol. Returns ------- None

Executor entrypoint for starting a pipeline's data collection. The bare task used to be fire-and-forget: an exception here died inside the

Extracts trading parameters from a request and validates them, including checking for the existence of a corresponding pipeline. Paramet

Fetches missing data on specified model class and for a specific symbol, candle_size and exchange from the Binance API. Parameters -

Calculates the end date for a batch of data based on the start date, candle size, and batch size. Parameters ---------- start_da

JWT signing key for service auth. Prefer a dedicated JWT_SECRET_KEY so a leaked Django SECRET_KEY can't be used to forge service tokens; fall

Retrieves a list of saved machine learning model filenames from a specified local directory. Parameters ---------- local_models_dir

Handles fatal errors from a trade execution. The wrapped call is made exactly once: transient connection errors are retried at the singl

Initiates trading for a specific symbol, setting initial parameters including leverage and position. Parameters ----------

Stops trading for a specific symbol and optionally forces the closure of any open positions. Parameters ---------- p

Applies a computed net value to the in-memory trading state.

Computes the new net value, units, and balances for a specified symbol without mutating any state. Pure on purpose: the resu

Converts the amount specified in quote currency to units of the base currency or adjusts units based on a factor. Parameters

Retrieves the current position amount for a given symbol. Parameters ---------- symbol : str The trading

Retrieves and stores trading symbol information, including base asset, quote asset, price precision, and quantity precision.

Writes the computed net value to the pipeline row. Must be called inside a transaction; the snapshot is deferred to after the commit