Runs a post-exchange bookkeeping operation, retrying once on a transient database error. If the database still cannot be written,

Validates the AWS S3 configuration by attempting to list objects in the specified bucket. Returns ------- bool Returns True

Retrieves the header information for a given pipeline from the Redis cache. Parameters ---------- pipeline_id : str or int T

Calculates the minimum lookback date required based on the maximum window size and the candle size. Parameters ---------- max_window

Calculates the number of batches needed to fetch historical data based on the start date, candle size, and batch size. Parameters --

Determines the maximum window size for a given pipeline by inspecting its strategies and parameters. Parameters ---------- pipeline_

Resolves the bot token and chat id: environment variables win, the database settings (editable from the dashboard) are the fallback.

Lists all the files in an AWS S3 bucket. Parameters ---------- client : boto3.client The boto3 S3 client instance used to in

RQ failure callback: makes failed signal jobs loud. Runs on the worker when a job raises; the job itself stays inspectable in the FailedJ

Generates a trading signal based on a composite strategy and attempts to execute a trade based on this signal. Parameters ----------

A queued job with no worker will silently expire after its ttl - make the outage loud. The job is still enqueued: a worker may come back in time.

Insert candle rows in bulk, splitting new rows from duplicates in a single existence query. Returns the number of rows counted as written (new

Checks if there is enough balance available for a given symbol based on the pipeline's current equity and leverage. Paramete

Checks for negative equity for a given symbol and raises an exception if found. Parameters ---------- symbol : str

Rewrites a single pipeline's units, Position row and dangling Trade to match the exchange. All writes happen in one transaction.

Reads the Telegram credentials saved from the dashboard. Imported lazily and guarded so the notifier stays usable (as a no-op) in any context

Sets the initial balance, units, and equity for a specified trading symbol based on the pipeline configuration. Parameters

Sets the leverage for a given symbol based on the pipeline configuration. Parameters ---------- pipeline : Pipeline

Computes, persists and applies a net value update in one step. Used outside the order path (e.g. when initializing a symbol's balance

Checks if requested symbol exists. Parameters ---------- symbol : str initialized symbol to check v

Iterates through all active pipelines, checking each for being stuck and for matching remote positions. Parameters ---------- positi

Checks for inconsistencies between local active pipeline positions and remote open positions. Closes any unmatched remote positions. Par

Verifies if there is a matching position on the remote trading platform for the given pipeline's symbol. If not, the pipeline is stopped (unl

Checks if a trading pipeline is stuck based on the time elapsed since its last entry. If it is determined to be stuck, a stop request is sent

Closes the position for a given symbol, optionally at a specific date and based on additional conditions. Parameters -------

Converts a database Trade object into a standardized Trade object with structured attributes. Parameters ---------- trade : Trade ob