Build a mock asyncio.subprocess.Process whose stdout/stderr are real StreamReaders pre-loaded with the given lines.

Inverse Contract is a contract using the coin itself as collateral if not inverted the contract uses fiat as the collateral :

:return: True if the instance is considered as open

Stops non-triggered tasks management

Called by finalize and MANUAL_TRIGGER user command. Override if necessary

Exact decimal view of a stored order price (avoids float + int mix in assertions).

Context manager for creating a temporary directory.

Add the producer to producers list Can be overwritten to perform additional action when registering Should end by calling 'pa

Should be overwritten according to the class needs Should end by calling '_check_producers_state' and then 'consumer.stop' :p

Returns the JSON representation of the model using alias

Handle new recent trades prices :param recent_trades: prices to check

Updates rows :param table_name: table to update data from :param row: updated data :param query: select query

Cancels the given order and updates the portfolio, publish in order channel if order is from a real exchange. :param order: O

Returns all consumers instance Can be overwritten according to the class needs :return: the subscribed consumers list

Context manager for creating a temporary TinyDB database.

Return the path to the main tentacles config file under reference config.

Check if the result is a re-calling operator result.

Create a VolatilityThresholdChecker instance with computed ratios. Ratios are computed manually to allow testing with zero percentage

Should be used to create temporary groups binding localized orders, where this group can be created once and directly associated to e

Helper function to create a real Order instance for testing.

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

Temporarily set _w3 on a wallet as open() would, then remove it.

Minimal dict shaped like packaged ``default_config.json`` for isolated ``read_file`` mocks.

Patch target for ``OctoBotActionsJob``: each constructor call receives ``result`` at index 3. Use ``run_on_result`` to mutate that object li

Execute an automation iteration: executed actions can be received priority actions or DAG's executable actions. In case of priority a

:return: the run database. Opens it if not open already

Returns or create the symbol position instance :param symbol: the position symbol :param side: the position side :ret

Handle balance update notification :return: True if profitability changed

Start the producer main task Shouldn't start the producer main task if the channel is synchronized Should always call

:return: True if the mode should be emitting trading signals according to configuration and trading environment

Build the exchange

Closes the database, flushes it first

Ensures API credentials are generated(lazy generation, similar to dYdX's retrieveCredentials) :param dict [params]: extra parameters

Ensures API credentials are generated(lazy generation, similar to dYdX's retrieveCredentials) :param dict [params]: extra parameters