Returns True when the given identifier is part of an existing database identifier :param identifier: the identifier to look into

Initialize data before starting jobs

Return True if the local event is set

Loads the available profiles :return: None

Prepare the expression by parsing it, leaving it ready to be computed one or multiple times. Call await self.compute_expression() to

Creates a new empty select query

Register the producer and call producer.start()

Withdraw funds from the exchange, requires constants.ALLOW_FUNDS_TRANSFER to be enabled (disabled by default) :param asset: the asset

Build DAG edge mappings from relations. Returns: Tuple of (incoming_edges, outgoing_edges) dicts. -

Return tentacles sorted so that build dependencies come before dependents. Uses iterative topological sort so that if tentacle B list

Add a new consumer to consumer list with filters :param consumer: the consumer to add :param consumer_filters: the consumer s

Use this as a context manager to get a free database cursor :yield: A free cursor :return: None

:return: A dict representation of this profile configuration

return True if the trader is enabled (not paused) or if the trading is paused but might be resumed

Closes the database

Compute the result of the expression stored in self._operator_tree_or_constant. If the expression is a constant, return it directly.

:param table_name: the table to count data from :param query: the query to count results from :return: the number of elements

:return: the total value (in quote) of paid fees when paid in base or quote of the trades pair

Returns the list of nodes related to the exchange_name, tentacle_type and tentacle_name, ignored if None :param matrix_id: the matrix id

Return the tentacles-specific config directory under reference config.

Push notification that new data should be sent implementation When nothing should be done on data : self.send()

Store a signal to be packed on build call

Stop the job by cancelling the execution task

Check if the DSL call succeeded :return: True if the DSL call succeeded, False otherwise

Trigger the event at the given path for the given bot_id (or create it)

Update or insert a row Upsert can be a very slow operation: avoid is as much as possible Upsert with uuid is fast though, try

OpenAPI oneOf bridge: runtime JSON uses flat user-action configuration payloads.

Copy fields from ``template`` onto ``target`` (real ``run()`` mutates ``OctoBotActionsJob.result`` in place).