Implemented in SupervisedConsumer to wait for any "perform" call to be finished. Instantly returns on regular consumer

Returns the value associated to the given timestamp :param timestamp: timestamp to get data for :param name: identifier of th

Called for a debug log :param message: the log message

Create the instance if not already created Return the class instance :param args: the constructor arguments :param kw

Called for a warning log :param message: the log message

Extend the interpreter with a list of operator classes.

Update the instance state if necessary. Necessary when the state is not already synchronizing and when the instance should be updated

Called for an info log :param message: the log message

Parse the specified symbol :param symbol_str: the symbol to parse

Creates a new asyncio task that contains start() execution

Called for an error log :param message: the log message :param skip_post_callback: when True, the error callback wont be call

Convert to dict. Returns: Dict representation of the execution plan.

Interpret a string expression by parsing it with AST and mapping to operators. Args: expression: String expression to in

Create an instance of Order from a dict

:return: the instance logger

Called for an exception log :param exception: the log exception :param publish_error_if_necessary: if the error should be pub

Find a tentacle from an iterable :param iterable: the iterable :param name: the tentacle name :return: the tentacle i

Set and return a user input value. The returned value is set as an attribute named as the "name" param with " " replaced by "_"

Get specified currency asset from portfolio :param currency: the currency to get :return: the currency portfolio asset instan

:param table_name: table to select data from :param query: select query :return: list of selected results

:return: the order logger

Set portfolio asset :return: True if updated

return a tuple made of this symbol's base and quote assets

Run the job if possible Reschedule the job in the end :param force: When True, force the execution of the job :param

:return: the database logger

Wait till the local event is triggered

Update the profile with new configuration values from the profile config dictionary. Only updates configurable fields, preserving run

Build a single-result return_values list for catalog metadata.

Updates the symbol contract position mode :param symbol: the symbol to update :param position_mode: the new position mode (en

Insert dict data into the table_name table :param table_name: name of the table :param row: data to insert

Set the contract current leverage value :param new_leverage: the new leverage value

Get the computed parameters of the operator. Here computed means that any nested operator has already been computed.

Returns internal producer if exists else creates it :param kwargs: arguments for internal producer __init__ :return: internal

Override using get_fixed_market_status in exchange tentacle if the default market status is not as expected

:param table: table name :return: True if the given table is in rows_cache

Return the complete default test configs :return: the complete default test config

Main async method to notify matrix to update :param cryptocurrency: evaluated cryptocurrency :param symbol: evaluated symbol

Create Like from Bird CLI JSON (tweet + optional likedAt).

Helper function to create a HedgingFill instance for testing.

Wait for next asyncio next loop cycle