Same as add_new_candle but also checks if old candles are missing :param candles_data: new candles data :return:

Creates an OctoBot managed order (managed orders example: stop loss that is not published on the exchange and that is maintained inte

Create a new FutureContract for the pair # TODO: support 1 contract by side when using hedge position mode --> think about another wa

Delete the node at the specified path :param path: the node path (as a list of string). For example: - If you created

Execute critic analysis of team execution. Args: input_data: Contains {"team_producer": team_producer, "execution_plan":

Reads a profile from the given dict :return: self

:return: The tentacles setup config for the activated profile. Profile-data-backed profiles use in-memory setup; filesystem profiles

Get the aiohttp authenticated session :return:

Parse injected upstream operator results from resolved operator parameters.

:return: the force side to take fees from (ex: pay fees only in USDT on BTC/BTC positions)

Get the team manager. Returns: The team manager agent, or None if not set.

Get the matrix from its id :param matrix_id: the matrix id :return: the matrix instance

Get a min string from number :param number: the number :param max_digits: the mex digits :return: the string from number

Default implementation is to return the name of the class without the 'Channel' substring :returns the channel name

Returns the position that matches the order :param order: the order :param contract: the symbol contract (optional) :

Helper method to get signature type from params or options with fallback to constants :param dict [params]: parameters that may contain sign

Helper method to get signature type from params or options with fallback to constants :param dict [params]: parameters that may contain sign

Returns the name of the only sub-identifier at a given parent identifier, None otherwise example use: get the name of the only exchan

SIGTERM all snapshot pids, wait, force-kill survivors. Returns per-pid outcome.

Default async State initialization process

:return: False if this contract can't be traded in OctoBot

True when ``historical_snapshots`` is non-empty but no stored snapshot aligns with the copier under grace checks, so grace cannot be

:return: True if the state is updating

Inserts multiple values into the given table :param table_name: name of the table :param rows: rows to insert :param

Called when an order referencing this group is filled This is called right before updating portfolio for this filled order and the

Updates the historical value only if the current timestamp or currency is missing, unless force_update is True :param timestamp: time

parses an order from the exchange response format :param dict order: order response from the exchange :param dict [market]: m

Try to extract JSON payloads from error strings produced by LLM parsers.