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)¶