Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
_
_backend_adapter (gromozeka.app.app.Gromozeka attribute)
(gromozeka.Gromozeka attribute)
(gromozeka.app.Gromozeka attribute)
_broker_adapter (gromozeka.app.app.Gromozeka attribute)
(gromozeka.Gromozeka attribute)
(gromozeka.app.Gromozeka attribute)
_event_queue (gromozeka.concurrency.Scheduler attribute)
(gromozeka.concurrency.scheduler.Scheduler attribute)
_scheduler (gromozeka.app.app.Gromozeka attribute)
(gromozeka.Gromozeka attribute)
(gromozeka.app.Gromozeka attribute)
_shed (gromozeka.concurrency.Scheduler attribute)
(gromozeka.concurrency.scheduler.Scheduler attribute)
_stop_event (gromozeka.concurrency.Pool attribute)
(gromozeka.ProcessWorker attribute)
(gromozeka.ThreadWorker attribute)
(gromozeka.concurrency.ProcessWorker attribute)
(gromozeka.concurrency.Scheduler attribute)
(gromozeka.concurrency.ThreadWorker attribute)
(gromozeka.concurrency.Worker attribute)
(gromozeka.concurrency.pool.Pool attribute)
(gromozeka.concurrency.scheduler.Scheduler attribute)
(gromozeka.concurrency.worker.ProcessWorker attribute)
(gromozeka.concurrency.worker.ThreadWorker attribute)
(gromozeka.concurrency.worker.Worker attribute)
A
a() (gromozeka.primitives.base.Task method)
(gromozeka.primitives.Task method)
acknowledge_message() (gromozeka.brokers.rabbit.Consumer method)
acquire() (gromozeka.brokers.LatexSema method)
add() (gromozeka.concurrency.Scheduler method)
(gromozeka.concurrency.scheduler.Scheduler method)
add_edge() (gromozeka.primitives.dag.Vertex method)
add_on_cancel_callback() (gromozeka.brokers.rabbit.Consumer method)
(gromozeka.brokers.rabbit.DelayedMessagePublisher method)
add_on_channel_close_callback() (gromozeka.brokers.rabbit.Consumer method)
(gromozeka.brokers.rabbit.DelayedMessagePublisher method)
add_on_connection_close_callback() (gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
add_task() (gromozeka.brokers.rabbit.Consumer method)
app (gromozeka.primitives.base.Task attribute)
(gromozeka.primitives.Task attribute)
apply() (gromozeka.primitives.dag.Vertex method)
apply_async() (gromozeka.primitives.base.Task method)
(gromozeka.primitives.Task method)
(gromozeka.primitives.dag.Graph method)
args (gromozeka.concurrency.commands.Command attribute)
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.base.Task attribute)
(gromozeka.primitives.task_pb2.Task attribute)
ARGS_FIELD_NUMBER (gromozeka.primitives.task_pb2.Task attribute)
as_dict() (gromozeka.concurrency.commands.Command method)
(gromozeka.primitives.dag.Graph method)
(gromozeka.primitives.dag.Vertex method)
as_tuple() (gromozeka.concurrency.commands.Command method)
async_error_handler() (in module gromozeka.backends.redis)
B
backend_adapter (gromozeka.app.app.Gromozeka attribute)
(gromozeka.Gromozeka attribute)
(gromozeka.app.Gromozeka attribute)
backend_chain_get_result() (in module gromozeka.concurrency.commands)
backend_graph_get() (in module gromozeka.concurrency.commands)
backend_graph_init() (in module gromozeka.concurrency.commands)
backend_graph_result_set() (in module gromozeka.concurrency.commands)
backend_graph_update() (in module gromozeka.concurrency.commands)
backend_group_add_result() (in module gromozeka.concurrency.commands)
backend_group_get_result() (in module gromozeka.concurrency.commands)
backend_is_group_completed() (in module gromozeka.concurrency.commands)
backend_reconnect_max_retries (gromozeka.config.Config attribute)
backend_reconnect_retry_countdown (gromozeka.config.Config attribute)
backend_result_del() (in module gromozeka.concurrency.commands)
backend_result_get() (in module gromozeka.concurrency.commands)
backend_result_set() (in module gromozeka.concurrency.commands)
backend_results_del() (in module gromozeka.concurrency.commands)
backend_results_timelife (gromozeka.config.Config attribute)
backend_url (gromozeka.config.Config attribute)
BackendAdapter (class in gromozeka.backends)
(class in gromozeka.backends.base)
BackendException
BackendInterface (class in gromozeka.backends.base)
bind (gromozeka.primitives.base.RegistryTask attribute)
,
[1]
(gromozeka.primitives.RegistryTask attribute)
,
[1]
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.base.Task attribute)
broker_adapter (gromozeka.app.app.Gromozeka attribute)
(gromozeka.Gromozeka attribute)
(gromozeka.app.Gromozeka attribute)
broker_on_pool_size_changed() (in module gromozeka.concurrency.commands)
broker_point (gromozeka.primitives.base.RegistryTask attribute)
,
[1]
(gromozeka.primitives.RegistryTask attribute)
,
[1]
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.base.Task attribute)
broker_reconnect_max_retries (gromozeka.config.Config attribute)
broker_reconnect_retry_countdown (gromozeka.config.Config attribute)
broker_task_done() (in module gromozeka.concurrency.commands)
broker_task_register() (in module gromozeka.concurrency.commands)
broker_task_reject() (in module gromozeka.concurrency.commands)
broker_task_send() (in module gromozeka.concurrency.commands)
broker_task_send_delayed() (in module gromozeka.concurrency.commands)
broker_url (gromozeka.config.Config attribute)
BrokerAdapter (class in gromozeka.brokers)
(class in gromozeka.brokers.base)
BrokerInterface (class in gromozeka.brokers.base)
BrokerPoint (class in gromozeka)
(class in gromozeka.primitives.base)
ByteSize() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint method)
(gromozeka.primitives.task_pb2.Task method)
C
cancel() (gromozeka.primitives.base.Task method)
(gromozeka.primitives.Task method)
chain_get_result() (gromozeka.backends.BackendAdapter method)
(gromozeka.backends.RedisAioredisAdaptee method)
(gromozeka.backends.base.BackendAdapter method)
(gromozeka.backends.base.BackendInterface method)
(gromozeka.backends.redis.RedisAioredisAdaptee method)
change() (gromozeka.brokers.LatexSema method)
change_prefetch_count() (gromozeka.brokers.rabbit.Consumer method)
Clear() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint method)
(gromozeka.primitives.task_pb2.Task method)
ClearField() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint method)
(gromozeka.primitives.task_pb2.Task method)
close_channel() (gromozeka.brokers.rabbit.Consumer method)
(gromozeka.brokers.rabbit.DelayedMessagePublisher method)
close_connection() (gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
cmd (gromozeka.concurrency.Pool attribute)
,
[1]
(gromozeka.concurrency.pool.Pool attribute)
,
[1]
cmd_out (gromozeka.concurrency.Pool attribute)
,
[1]
(gromozeka.concurrency.pool.Pool attribute)
,
[1]
Command (class in gromozeka.concurrency.commands)
command (gromozeka.concurrency.commands.Command attribute)
Config (class in gromozeka.config)
config (gromozeka.app.app.Gromozeka attribute)
,
[1]
(gromozeka.Gromozeka attribute)
,
[1]
(gromozeka.app.Gromozeka attribute)
,
[1]
config_from_dict() (gromozeka.app.app.Gromozeka method)
(gromozeka.Gromozeka method)
(gromozeka.app.Gromozeka method)
config_from_env() (gromozeka.app.app.Gromozeka method)
(gromozeka.Gromozeka method)
(gromozeka.app.Gromozeka method)
configure() (gromozeka.backends.base.BackendInterface method)
(gromozeka.backends.RedisAioredisAdaptee method)
(gromozeka.backends.redis.RedisAioredisAdaptee method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
(gromozeka.brokers.base.BrokerInterface method)
(gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
connect() (gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
connection (gromozeka.brokers.rabbit.RabbitMQPikaAdaptee attribute)
(gromozeka.brokers.RabbitMQPikaAdaptee attribute)
Consumer (class in gromozeka.brokers.rabbit)
D
debug (gromozeka.config.Config attribute)
delay (gromozeka.primitives.base.Task attribute)
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.task_pb2.Task attribute)
delay() (in module gromozeka.concurrency.scheduler)
DELAY_FIELD_NUMBER (gromozeka.primitives.task_pb2.Task attribute)
delay_from_eta() (in module gromozeka.concurrency.scheduler)
DelayedMessagePublisher (class in gromozeka.brokers.rabbit)
delivery_tag (gromozeka.primitives.base.Task attribute)
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.task_pb2.Task attribute)
DELIVERY_TAG_FIELD_NUMBER (gromozeka.primitives.task_pb2.Task attribute)
DESCRIPTOR (gromozeka.primitives.task_pb2.ReplyToBrokerPoint attribute)
(gromozeka.primitives.task_pb2.Task attribute)
deserializator (gromozeka.primitives.base.RegistryTask attribute)
(gromozeka.primitives.RegistryTask attribute)
deserialize() (gromozeka.primitives.base.TaskDeserializator method)
(gromozeka.TaskDeserializator method)
DiscardUnknownFields() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint method)
(gromozeka.primitives.task_pb2.Task method)
draw() (gromozeka.primitives.dag.Graph method)
E
exchange (gromozeka.brokers.rabbit.DelayedMessagePublisher attribute)
(gromozeka.primitives.task_pb2.ReplyToBrokerPoint attribute)
EXCHANGE_FIELD_NUMBER (gromozeka.primitives.task_pb2.ReplyToBrokerPoint attribute)
exchange_type (gromozeka.brokers.rabbit.DelayedMessagePublisher attribute)
F
FindInitializationErrors() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint method)
(gromozeka.primitives.task_pb2.Task method)
first (gromozeka.primitives.dag.Graph attribute)
first_uuid (gromozeka.primitives.dag.Graph attribute)
format_consumer_id_from_broker_point() (in module gromozeka.brokers.rabbit)
from_dict() (gromozeka.config.Config method)
(gromozeka.primitives.dag.Graph class method)
from_env() (gromozeka.config.Config method)
from_proto() (gromozeka.primitives.base.Task class method)
(gromozeka.primitives.Task class method)
FromString() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint static method)
(gromozeka.primitives.task_pb2.Task static method)
func (gromozeka.primitives.base.RegistryTask attribute)
,
[1]
(gromozeka.primitives.RegistryTask attribute)
,
[1]
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.base.Task attribute)
G
get_app() (in module gromozeka)
(in module gromozeka.app)
(in module gromozeka.app.app)
get_backend_factory() (in module gromozeka.backends)
(in module gromozeka.backends.base)
get_broker_factory() (in module gromozeka.brokers)
(in module gromozeka.brokers.base)
get_consumer() (gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
get_task() (gromozeka.app.app.Gromozeka method)
(gromozeka.Gromozeka method)
(gromozeka.app.Gromozeka method)
Graph (class in gromozeka.primitives.dag)
graph_get() (gromozeka.backends.BackendAdapter method)
(gromozeka.backends.RedisAioredisAdaptee method)
(gromozeka.backends.base.BackendAdapter method)
(gromozeka.backends.base.BackendInterface method)
(gromozeka.backends.redis.RedisAioredisAdaptee method)
graph_init() (gromozeka.backends.BackendAdapter method)
(gromozeka.backends.RedisAioredisAdaptee method)
(gromozeka.backends.base.BackendAdapter method)
(gromozeka.backends.base.BackendInterface method)
(gromozeka.backends.redis.RedisAioredisAdaptee method)
graph_result_set() (gromozeka.backends.BackendAdapter method)
(gromozeka.backends.RedisAioredisAdaptee method)
(gromozeka.backends.base.BackendAdapter method)
(gromozeka.backends.base.BackendInterface method)
(gromozeka.backends.redis.RedisAioredisAdaptee method)
graph_update() (gromozeka.backends.BackendAdapter method)
(gromozeka.backends.RedisAioredisAdaptee method)
(gromozeka.backends.base.BackendAdapter method)
(gromozeka.backends.base.BackendInterface method)
(gromozeka.backends.redis.RedisAioredisAdaptee method)
graph_uuid (gromozeka.primitives.base.Task attribute)
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.task_pb2.Task attribute)
GRAPH_UUID_FIELD_NUMBER (gromozeka.primitives.task_pb2.Task attribute)
Gromozeka (class in gromozeka)
(class in gromozeka.app)
(class in gromozeka.app.app)
gromozeka (module)
gromozeka.app (module)
gromozeka.app.app (module)
gromozeka.backends (module)
gromozeka.backends.base (module)
gromozeka.backends.redis (module)
gromozeka.brokers (module)
gromozeka.brokers.base (module)
gromozeka.brokers.rabbit (module)
gromozeka.concurrency (module)
gromozeka.concurrency.commands (module)
gromozeka.concurrency.pool (module)
gromozeka.concurrency.scheduler (module)
gromozeka.concurrency.worker (module)
gromozeka.config (module)
gromozeka.exceptions (module)
gromozeka.primitives (module)
gromozeka.primitives.base (module)
gromozeka.primitives.dag (module)
gromozeka.primitives.task_pb2 (module)
GromozekaException
,
[1]
group_add_result() (gromozeka.backends.BackendAdapter method)
(gromozeka.backends.RedisAioredisAdaptee method)
(gromozeka.backends.base.BackendAdapter method)
(gromozeka.backends.base.BackendInterface method)
(gromozeka.backends.redis.RedisAioredisAdaptee method)
group_get_result() (gromozeka.backends.BackendAdapter method)
(gromozeka.backends.RedisAioredisAdaptee method)
(gromozeka.backends.base.BackendAdapter method)
(gromozeka.backends.base.BackendInterface method)
(gromozeka.backends.redis.RedisAioredisAdaptee method)
grow() (gromozeka.concurrency.Pool method)
(gromozeka.concurrency.pool.Pool method)
H
HasField() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint method)
(gromozeka.primitives.task_pb2.Task method)
I
ident (gromozeka.concurrency.Worker attribute)
(gromozeka.concurrency.worker.Worker attribute)
ignore_result (gromozeka.primitives.base.RegistryTask attribute)
(gromozeka.primitives.RegistryTask attribute)
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.base.Task attribute)
init_max_workers (gromozeka.concurrency.Pool attribute)
(gromozeka.concurrency.pool.Pool attribute)
is_alive() (gromozeka.concurrency.Worker method)
(gromozeka.concurrency.worker.Worker method)
is_chain_part() (gromozeka.primitives.dag.Graph method)
is_chain_tail() (gromozeka.primitives.dag.Graph method)
is_closing (gromozeka.app.app.Gromozeka attribute)
(gromozeka.Gromozeka attribute)
(gromozeka.app.Gromozeka attribute)
is_group_completed() (gromozeka.backends.BackendAdapter method)
(gromozeka.backends.RedisAioredisAdaptee method)
(gromozeka.backends.base.BackendAdapter method)
(gromozeka.backends.base.BackendInterface method)
(gromozeka.backends.redis.RedisAioredisAdaptee method)
is_group_part() (gromozeka.primitives.dag.Graph method)
is_on_stop (gromozeka.concurrency.Pool attribute)
(gromozeka.concurrency.pool.Pool attribute)
IsInitialized() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint method)
(gromozeka.primitives.task_pb2.Task method)
K
k() (gromozeka.primitives.base.Task method)
(gromozeka.primitives.Task method)
kwargs (gromozeka.primitives.base.Task attribute)
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.task_pb2.Task attribute)
KWARGS_FIELD_NUMBER (gromozeka.primitives.task_pb2.Task attribute)
L
last (gromozeka.primitives.dag.Graph attribute)
last_uuid (gromozeka.primitives.dag.Graph attribute)
LatexSema (class in gromozeka.brokers)
listen_cmd() (gromozeka.backends.BackendAdapter method)
(gromozeka.backends.base.BackendAdapter method)
(gromozeka.brokers.BrokerAdapter method)
(gromozeka.brokers.base.BrokerAdapter method)
(gromozeka.concurrency.Pool method)
(gromozeka.concurrency.Scheduler method)
(gromozeka.concurrency.pool.Pool method)
(gromozeka.concurrency.scheduler.Scheduler method)
ListFields() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint method)
(gromozeka.primitives.task_pb2.Task method)
logger (gromozeka.app.app.Gromozeka attribute)
,
[1]
(gromozeka.Gromozeka attribute)
,
[1]
(gromozeka.ProcessWorker attribute)
(gromozeka.ThreadWorker attribute)
(gromozeka.app.Gromozeka attribute)
,
[1]
(gromozeka.concurrency.Pool attribute)
,
[1]
(gromozeka.concurrency.ProcessWorker attribute)
(gromozeka.concurrency.Scheduler attribute)
,
[1]
(gromozeka.concurrency.ThreadWorker attribute)
(gromozeka.concurrency.Worker attribute)
(gromozeka.concurrency.pool.Pool attribute)
,
[1]
(gromozeka.concurrency.scheduler.Scheduler attribute)
,
[1]
(gromozeka.concurrency.worker.ProcessWorker attribute)
(gromozeka.concurrency.worker.ThreadWorker attribute)
(gromozeka.concurrency.worker.Worker attribute)
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.base.Task attribute)
M
manual_ack (gromozeka.primitives.base.Task attribute)
(gromozeka.primitives.Task attribute)
max_retries (gromozeka.exceptions.Retry attribute)
(gromozeka.Retry attribute)
(gromozeka.primitives.RegistryTask attribute)
,
[1]
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.base.RegistryTask attribute)
,
[1]
(gromozeka.primitives.base.Task attribute)
max_workers (gromozeka.concurrency.Pool attribute)
(gromozeka.concurrency.pool.Pool attribute)
(gromozeka.primitives.RegistryTask attribute)
,
[1]
(gromozeka.primitives.base.RegistryTask attribute)
,
[1]
MaxRetriesExceedException
,
[1]
MergeFrom() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint method)
(gromozeka.primitives.task_pb2.Task method)
MergeFromString() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint method)
(gromozeka.primitives.task_pb2.Task method)
N
name (gromozeka.concurrency.Worker attribute)
(gromozeka.concurrency.worker.Worker attribute)
new_eta() (in module gromozeka.concurrency.scheduler)
next_vertex() (gromozeka.primitives.dag.Graph method)
O
on_bindok() (gromozeka.brokers.rabbit.Consumer method)
(gromozeka.brokers.rabbit.DelayedMessagePublisher method)
on_cancel() (gromozeka.primitives.base.Task method)
(gromozeka.primitives.Task method)
on_cancelok() (gromozeka.brokers.rabbit.Consumer method)
(gromozeka.brokers.rabbit.DelayedMessagePublisher method)
on_channel_closed() (gromozeka.brokers.rabbit.Consumer method)
(gromozeka.brokers.rabbit.DelayedMessagePublisher method)
on_channel_open() (gromozeka.brokers.rabbit.Consumer method)
(gromozeka.brokers.rabbit.DelayedMessagePublisher method)
on_connection_closed() (gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
on_connection_open() (gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
on_consumer_cancelled() (gromozeka.brokers.rabbit.Consumer method)
(gromozeka.brokers.rabbit.DelayedMessagePublisher method)
on_exchange_declareok() (gromozeka.brokers.rabbit.Consumer method)
(gromozeka.brokers.rabbit.DelayedMessagePublisher method)
on_fail() (gromozeka.primitives.base.Task method)
(gromozeka.primitives.Task method)
on_message() (gromozeka.brokers.rabbit.Consumer method)
on_pool_size_changed() (gromozeka.brokers.base.BrokerAdapter method)
(gromozeka.brokers.BrokerAdapter method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
(gromozeka.brokers.base.BrokerInterface method)
(gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
on_queue_declareok() (gromozeka.brokers.rabbit.Consumer method)
(gromozeka.brokers.rabbit.DelayedMessagePublisher method)
on_receive() (gromozeka.primitives.base.Task method)
(gromozeka.primitives.Task method)
on_reject() (gromozeka.primitives.base.Task method)
(gromozeka.primitives.Task method)
on_retry() (gromozeka.primitives.base.Task method)
(gromozeka.primitives.Task method)
on_start() (gromozeka.primitives.base.Task method)
(gromozeka.primitives.Task method)
on_success() (gromozeka.primitives.base.Task method)
(gromozeka.primitives.Task method)
open_channel() (gromozeka.brokers.rabbit.Consumer method)
(gromozeka.brokers.rabbit.DelayedMessagePublisher method)
P
pid (gromozeka.app.app.Gromozeka attribute)
(gromozeka.Gromozeka attribute)
(gromozeka.app.Gromozeka attribute)
Pool (class in gromozeka.concurrency)
(class in gromozeka.concurrency.pool)
pool (gromozeka.concurrency.ProcessWorker attribute)
(gromozeka.ProcessWorker attribute)
(gromozeka.ThreadWorker attribute)
(gromozeka.concurrency.ThreadWorker attribute)
(gromozeka.concurrency.Worker attribute)
(gromozeka.concurrency.worker.ProcessWorker attribute)
(gromozeka.concurrency.worker.ThreadWorker attribute)
(gromozeka.concurrency.worker.Worker attribute)
(gromozeka.primitives.RegistryTask attribute)
,
[1]
(gromozeka.primitives.base.RegistryTask attribute)
,
[1]
pool_grow() (in module gromozeka.concurrency.commands)
pool_remove_worker() (in module gromozeka.concurrency.commands)
pool_shrink() (in module gromozeka.concurrency.commands)
pool_size() (in module gromozeka.concurrency.commands)
pool_stop() (in module gromozeka.concurrency.commands)
ProcessWorker (class in gromozeka)
(class in gromozeka.concurrency)
(class in gromozeka.concurrency.worker)
ProtoReplyToBrokerPoint (in module gromozeka)
(in module gromozeka.primitives)
ProtoTask (in module gromozeka)
(in module gromozeka.primitives)
publish() (gromozeka.brokers.rabbit.Consumer method)
(gromozeka.brokers.rabbit.DelayedMessagePublisher method)
R
RabbitMQPikaAdaptee (class in gromozeka.brokers)
(class in gromozeka.brokers.rabbit)
reconnect() (gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
reconnect_max_retries (gromozeka.backends.redis.RedisAioredisAdaptee attribute)
(gromozeka.backends.RedisAioredisAdaptee attribute)
(gromozeka.brokers.RabbitMQPikaAdaptee attribute)
(gromozeka.brokers.rabbit.RabbitMQPikaAdaptee attribute)
reconnect_retry_countdown (gromozeka.backends.redis.RedisAioredisAdaptee attribute)
(gromozeka.backends.RedisAioredisAdaptee attribute)
(gromozeka.brokers.RabbitMQPikaAdaptee attribute)
(gromozeka.brokers.rabbit.RabbitMQPikaAdaptee attribute)
RedisAioredisAdaptee (class in gromozeka.backends)
(class in gromozeka.backends.redis)
register() (gromozeka.app.app.Gromozeka method)
(gromozeka.Gromozeka method)
(gromozeka.app.Gromozeka method)
(gromozeka.primitives.Task method)
(gromozeka.primitives.base.Task method)
RegisterExtension() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint static method)
(gromozeka.primitives.task_pb2.Task static method)
registry (gromozeka.app.app.Gromozeka attribute)
,
[1]
(gromozeka.Gromozeka attribute)
,
[1]
(gromozeka.app.Gromozeka attribute)
,
[1]
RegistryTask (class in gromozeka.primitives)
(class in gromozeka.primitives.base)
reject_message() (gromozeka.brokers.rabbit.Consumer method)
release() (gromozeka.brokers.LatexSema method)
remove_worker() (gromozeka.concurrency.Pool method)
(gromozeka.concurrency.pool.Pool method)
reply_to (gromozeka.primitives.task_pb2.Task attribute)
reply_to_exchange (gromozeka.primitives.base.Task attribute)
(gromozeka.primitives.Task attribute)
REPLY_TO_FIELD_NUMBER (gromozeka.primitives.task_pb2.Task attribute)
reply_to_routing_key (gromozeka.primitives.base.Task attribute)
(gromozeka.primitives.Task attribute)
ReplyToBrokerPoint (class in gromozeka.primitives.task_pb2)
request (gromozeka.primitives.base.Task attribute)
(gromozeka.primitives.Task attribute)
result_del() (gromozeka.backends.BackendAdapter method)
(gromozeka.backends.RedisAioredisAdaptee method)
(gromozeka.backends.base.BackendAdapter method)
(gromozeka.backends.base.BackendInterface method)
(gromozeka.backends.redis.RedisAioredisAdaptee method)
result_get() (gromozeka.backends.BackendAdapter method)
(gromozeka.backends.RedisAioredisAdaptee method)
(gromozeka.backends.base.BackendAdapter method)
(gromozeka.backends.base.BackendInterface method)
(gromozeka.backends.redis.RedisAioredisAdaptee method)
result_queue (gromozeka.backends.redis.RedisAioredisAdaptee attribute)
(gromozeka.backends.RedisAioredisAdaptee attribute)
result_set() (gromozeka.backends.BackendAdapter method)
(gromozeka.backends.RedisAioredisAdaptee method)
(gromozeka.backends.base.BackendAdapter method)
(gromozeka.backends.base.BackendInterface method)
(gromozeka.backends.redis.RedisAioredisAdaptee method)
results_del() (gromozeka.backends.BackendAdapter method)
(gromozeka.backends.RedisAioredisAdaptee method)
(gromozeka.backends.base.BackendAdapter method)
(gromozeka.backends.base.BackendInterface method)
(gromozeka.backends.redis.RedisAioredisAdaptee method)
retries (gromozeka.primitives.base.Task attribute)
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.task_pb2.Task attribute)
RETRIES_FIELD_NUMBER (gromozeka.primitives.task_pb2.Task attribute)
Retry
,
[1]
retry_countdown (gromozeka.exceptions.Retry attribute)
(gromozeka.Retry attribute)
(gromozeka.primitives.RegistryTask attribute)
,
[1]
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.base.RegistryTask attribute)
,
[1]
(gromozeka.primitives.base.Task attribute)
routing_key (gromozeka.primitives.task_pb2.ReplyToBrokerPoint attribute)
ROUTING_KEY_FIELD_NUMBER (gromozeka.primitives.task_pb2.ReplyToBrokerPoint attribute)
run() (gromozeka.concurrency.Pool method)
(gromozeka.ProcessWorker method)
(gromozeka.ThreadWorker method)
(gromozeka.concurrency.ProcessWorker method)
(gromozeka.concurrency.Scheduler method)
(gromozeka.concurrency.ThreadWorker method)
(gromozeka.concurrency.Worker method)
(gromozeka.concurrency.pool.Pool method)
(gromozeka.concurrency.scheduler.Scheduler method)
(gromozeka.concurrency.worker.ProcessWorker method)
(gromozeka.concurrency.worker.ThreadWorker method)
(gromozeka.concurrency.worker.Worker method)
S
Scheduler (class in gromozeka.concurrency)
(class in gromozeka.concurrency.scheduler)
scheduler (gromozeka.app.app.Gromozeka attribute)
(gromozeka.Gromozeka attribute)
(gromozeka.app.Gromozeka attribute)
SerializationError
SerializePartialToString() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint method)
(gromozeka.primitives.task_pb2.Task method)
SerializeToString() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint method)
(gromozeka.primitives.task_pb2.Task method)
serve() (gromozeka.backends.redis.RedisAioredisAdaptee method)
(gromozeka.backends.RedisAioredisAdaptee method)
SetInParent() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint method)
(gromozeka.primitives.task_pb2.Task method)
setup_exchange() (gromozeka.brokers.rabbit.Consumer method)
(gromozeka.brokers.rabbit.DelayedMessagePublisher method)
setup_queue() (gromozeka.brokers.rabbit.Consumer method)
(gromozeka.brokers.rabbit.DelayedMessagePublisher method)
shrink() (gromozeka.concurrency.Pool method)
(gromozeka.concurrency.pool.Pool method)
size (gromozeka.concurrency.Pool attribute)
(gromozeka.concurrency.pool.Pool attribute)
start() (gromozeka.app.app.Gromozeka method)
(gromozeka.Gromozeka method)
(gromozeka.app.Gromozeka method)
(gromozeka.backends.BackendAdapter method)
(gromozeka.backends.base.BackendAdapter method)
(gromozeka.brokers.BrokerAdapter method)
(gromozeka.brokers.base.BrokerAdapter method)
(gromozeka.concurrency.Pool method)
(gromozeka.concurrency.pool.Pool method)
start_consuming() (gromozeka.brokers.rabbit.Consumer method)
state (gromozeka.primitives.base.Task attribute)
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.task_pb2.Task attribute)
STATE_FIELD_NUMBER (gromozeka.primitives.task_pb2.Task attribute)
stop() (gromozeka.app.app.Gromozeka method)
(gromozeka.Gromozeka method)
(gromozeka.ProcessWorker method)
(gromozeka.ThreadWorker method)
(gromozeka.app.Gromozeka method)
(gromozeka.backends.RedisAioredisAdaptee method)
(gromozeka.backends.base.BackendInterface method)
(gromozeka.backends.redis.RedisAioredisAdaptee method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
(gromozeka.brokers.base.BrokerInterface method)
(gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
(gromozeka.concurrency.Pool method)
(gromozeka.concurrency.ProcessWorker method)
(gromozeka.concurrency.Scheduler method)
(gromozeka.concurrency.ThreadWorker method)
(gromozeka.concurrency.Worker method)
(gromozeka.concurrency.pool.Pool method)
(gromozeka.concurrency.scheduler.Scheduler method)
(gromozeka.concurrency.worker.ProcessWorker method)
(gromozeka.concurrency.worker.ThreadWorker method)
(gromozeka.concurrency.worker.Worker method)
stop_() (gromozeka.concurrency.Pool method)
(gromozeka.concurrency.pool.Pool method)
stop_consuming() (gromozeka.brokers.rabbit.Consumer method)
stop_serve() (gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
stop_signal() (gromozeka.app.app.Gromozeka method)
(gromozeka.Gromozeka method)
(gromozeka.app.Gromozeka method)
T
Task (class in gromozeka.primitives)
(class in gromozeka.primitives.base)
(class in gromozeka.primitives.task_pb2)
task() (in module gromozeka)
(in module gromozeka.primitives)
(in module gromozeka.primitives.base)
task_done() (gromozeka.brokers.base.BrokerAdapter method)
(gromozeka.brokers.BrokerAdapter method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
(gromozeka.brokers.base.BrokerInterface method)
(gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
task_id (gromozeka.primitives.base.RegistryTask attribute)
,
[1]
(gromozeka.primitives.RegistryTask attribute)
,
[1]
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.base.Task attribute)
(gromozeka.primitives.task_pb2.Task attribute)
TASK_ID_FIELD_NUMBER (gromozeka.primitives.task_pb2.Task attribute)
task_register() (gromozeka.brokers.base.BrokerAdapter method)
(gromozeka.brokers.BrokerAdapter method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
(gromozeka.brokers.base.BrokerInterface method)
(gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
task_reject() (gromozeka.brokers.base.BrokerAdapter method)
(gromozeka.brokers.BrokerAdapter method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
(gromozeka.brokers.base.BrokerInterface method)
(gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
task_send() (gromozeka.brokers.base.BrokerAdapter method)
(gromozeka.brokers.BrokerAdapter method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
(gromozeka.brokers.base.BrokerInterface method)
(gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
task_send_delayed() (gromozeka.brokers.base.BrokerAdapter method)
(gromozeka.brokers.BrokerAdapter method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
(gromozeka.brokers.base.BrokerInterface method)
(gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
TaskDeserializator (class in gromozeka)
(class in gromozeka.primitives.base)
ThreadWorker (class in gromozeka)
(class in gromozeka.concurrency)
(class in gromozeka.concurrency.worker)
to_dict() (in module gromozeka.primitives.base)
U
update_graph_states() (gromozeka.primitives.base.Task method)
(gromozeka.primitives.Task method)
uuid (gromozeka.primitives.base.Task attribute)
(gromozeka.primitives.Task attribute)
(gromozeka.primitives.task_pb2.Task attribute)
UUID_FIELD_NUMBER (gromozeka.primitives.task_pb2.Task attribute)
V
Vertex (class in gromozeka.primitives.dag)
vertex_by_uuid() (gromozeka.primitives.dag.Graph method)
W
wait_for_start() (gromozeka.brokers.base.BrokerInterface method)
(gromozeka.brokers.RabbitMQPikaAdaptee method)
(gromozeka.brokers.rabbit.RabbitMQPikaAdaptee method)
WhichOneof() (gromozeka.primitives.task_pb2.ReplyToBrokerPoint method)
(gromozeka.primitives.task_pb2.Task method)
Worker (class in gromozeka.concurrency)
(class in gromozeka.concurrency.worker)
worker_class (gromozeka.concurrency.Pool attribute)
(gromozeka.concurrency.pool.Pool attribute)
(gromozeka.primitives.RegistryTask attribute)
,
[1]
(gromozeka.primitives.base.RegistryTask attribute)
,
[1]
worker_cls (gromozeka.concurrency.Pool attribute)
(gromozeka.concurrency.pool.Pool attribute)
worker_queue (gromozeka.concurrency.Pool attribute)
,
[1]
(gromozeka.concurrency.pool.Pool attribute)
,
[1]
worker_run() (gromozeka.backends.base.BackendInterface static method)
(gromozeka.backends.RedisAioredisAdaptee static method)
(gromozeka.backends.redis.RedisAioredisAdaptee static method)
(gromozeka.brokers.RabbitMQPikaAdaptee static method)
(gromozeka.brokers.base.BrokerInterface static method)
(gromozeka.brokers.rabbit.RabbitMQPikaAdaptee static method)
workers (gromozeka.concurrency.Pool attribute)
,
[1]
(gromozeka.concurrency.pool.Pool attribute)
,
[1]
Table Of Contents
Configuration
How to configure logging
Making and running tasks
Running tasks from outer application
How to retry task
Building task workflows
Visualization of the workflow
gromozeka
Related Topics
Documentation overview
Quick search