gromozeka.backends package¶
Submodules¶
gromozeka.backends.base module¶
-
class
gromozeka.backends.base.
BackendAdapter
(backend, logger=None)¶ Bases:
gromozeka.concurrency.pool.Pool
-
chain_get_result
(graph_uuid, chain_uuid)¶
-
graph_get
(graph_uuid)¶
-
graph_init
(graph_dict)¶
-
graph_result_set
(graph_uuid, task_uuid, result)¶
-
graph_update
(graph_uuid, verticies, graph_state=None, error_task_uuid=None, short_error=None)¶
-
group_add_result
(graph_uuid, group_uuid, task_uuid, result)¶
-
group_get_result
(graph_uuid, group_uuid)¶
-
is_group_completed
(graph_uuid, group_uuid, expected)¶
-
listen_cmd
()¶ Listen to commands
-
result_del
(task_uuid)¶
-
result_get
(task_uuid, graph_uuid=None)¶
-
result_set
(task_uuid, result, graph_uuid=None)¶
-
results_del
(*task_uuids)¶
-
start
()¶ Start pool
-
-
class
gromozeka.backends.base.
BackendInterface
(app)¶ Bases:
object
-
chain_get_result
(graph_uuid, chain_uuid)¶
-
configure
()¶
-
graph_get
(graph_uuid)¶
-
graph_init
(graph_dict)¶
-
graph_result_set
(graph_uuid, task_uuid, result)¶
-
graph_update
(graph_uuid, verticies, graph_state=None, error_task_uuid=None, short_error=None)¶
-
group_add_result
(graph_uuid, group_uuid, task_uuid, result)¶
-
group_get_result
(graph_uuid, group_uuid)¶
-
is_group_completed
(graph_uuid, group_uuid, expected)¶
-
result_del
(task_uuid)¶
-
result_get
(task_uuid, graph_uuid=None)¶
-
result_set
(task_uuid, result, graph_uuid=None)¶
-
results_del
(*task_uuids)¶
-
stop
()¶ Stop backend_adapter
-
static
worker_run
(self)¶ This method will be in thread - start to work here
-
-
gromozeka.backends.base.
get_backend_factory
(app)¶ Parameters: app (gromozeka.app.app.Gromozeka) – Returns: Return type: gromozeka.backends.base.BackendInterface
gromozeka.backends.redis module¶
-
class
gromozeka.backends.redis.
RedisAioredisAdaptee
(app)¶ Bases:
gromozeka.backends.base.BackendInterface
-
chain_get_result
(graph_uuid, chain_uuid)¶
-
configure
()¶
-
graph_get
(graph_uuid)¶
-
graph_init
(graph_dict)¶
-
graph_result_set
(graph_uuid, task_uuid, result)¶
-
graph_update
(graph_uuid, verticies, graph_state=None, error_task_uuid=None, short_error=None)¶
-
group_add_result
(graph_uuid, group_uuid, task_uuid, result)¶
-
group_get_result
(graph_uuid, group_uuid)¶
-
is_group_completed
(graph_uuid, group_uuid, expected)¶
-
reconnect_max_retries
= None¶
-
reconnect_retry_countdown
= None¶
-
result_del
(task_uuid)¶
-
result_get
(task_uuid, graph_uuid=None)¶
-
result_queue
= None¶
-
result_set
(task_uuid, result, graph_uuid=None)¶
-
results_del
(*task_uuids)¶
-
serve
()¶ Start Backend
-
stop
()¶ Stop backend_adapter
-
static
worker_run
(self)¶ Parameters: self (gromozeka.backends.base.BackendAdapter) –
-
-
gromozeka.backends.redis.
async_error_handler
(func)¶ Returns: Return type: function
Module contents¶
-
class
gromozeka.backends.
BackendAdapter
(backend, logger=None)¶ Bases:
gromozeka.concurrency.pool.Pool
-
chain_get_result
(graph_uuid, chain_uuid)¶
-
graph_get
(graph_uuid)¶
-
graph_init
(graph_dict)¶
-
graph_result_set
(graph_uuid, task_uuid, result)¶
-
graph_update
(graph_uuid, verticies, graph_state=None, error_task_uuid=None, short_error=None)¶
-
group_add_result
(graph_uuid, group_uuid, task_uuid, result)¶
-
group_get_result
(graph_uuid, group_uuid)¶
-
is_group_completed
(graph_uuid, group_uuid, expected)¶
-
listen_cmd
()¶ Listen to commands
-
result_del
(task_uuid)¶
-
result_get
(task_uuid, graph_uuid=None)¶
-
result_set
(task_uuid, result, graph_uuid=None)¶
-
results_del
(*task_uuids)¶
-
start
()¶ Start pool
-
-
class
gromozeka.backends.
RedisAioredisAdaptee
(app)¶ Bases:
gromozeka.backends.base.BackendInterface
-
chain_get_result
(graph_uuid, chain_uuid)¶
-
configure
()¶
-
graph_get
(graph_uuid)¶
-
graph_init
(graph_dict)¶
-
graph_result_set
(graph_uuid, task_uuid, result)¶
-
graph_update
(graph_uuid, verticies, graph_state=None, error_task_uuid=None, short_error=None)¶
-
group_add_result
(graph_uuid, group_uuid, task_uuid, result)¶
-
group_get_result
(graph_uuid, group_uuid)¶
-
is_group_completed
(graph_uuid, group_uuid, expected)¶
-
reconnect_max_retries
= None¶
-
reconnect_retry_countdown
= None¶
-
result_del
(task_uuid)¶
-
result_get
(task_uuid, graph_uuid=None)¶
-
result_queue
= None¶
-
result_set
(task_uuid, result, graph_uuid=None)¶
-
results_del
(*task_uuids)¶
-
serve
()¶ Start Backend
-
stop
()¶ Stop backend_adapter
-
static
worker_run
(self)¶ Parameters: self (gromozeka.backends.base.BackendAdapter) –
-
-
gromozeka.backends.
get_backend_factory
(app)¶ Parameters: app (gromozeka.app.app.Gromozeka) – Returns: Return type: gromozeka.backends.base.BackendInterface