gromozeka.app package

Submodules

gromozeka.app.app module

class gromozeka.app.app.Gromozeka

Bases: object

logger

logging.Logger – Class logger

registry

dict of gromozeka.primitives.Task – Task registry

config

gromozeka.config.Config – config object

_broker_adapter

gromozeka.brokers.BrokerAdapter – Broker

_backend_adapter

gromozeka.backends.BackendAdapter – Broker

_scheduler

gromozeka.concurrency.Scheduler – Scheduler

backend_adapter

broker_adapter

config

config_from_dict(conf)

Configure Gromozeka with dict

Examples

conf={'app_prefix':'my_application','broker_reconnect_max_retries':3}
app=Gromozeka().config_from_dict(conf)

Parameters:conf (dict) – config dict Returns:Configured application Return type:gromozeka.Gromozeka

config_from_env()

Configure Gromozeka with environment variables

Examples

app=Gromozeka().config_from_env()

Returns:Configured application Return type:gromozeka.Gromozeka

get_task(id_)

Get task by id

Parameters:id (str) – Unique task identification Returns:registry task Return type:gromozeka.primitives.RegistryTask

is_closing

logger

pid

register(task, broker_point, worker_class=None, max_workers=1, max_retries=0, retry_countdown=0, ignore_result=False, broker_options=None, deserializator=None)

Parameters:

• task (gromozeka.primitives.Task or gromozeka.primitives.RegistryTask) – Task
• broker_point (gromozeka.primitives.BrokerPointType) – Broker entry
• worker_class (gromozeka.concurrency.Worker, optional) – Worker class
• max_workers (int) – How match workers will start
• max_retries (int) – Maximum number of retries, after it will reached task will down
• retry_countdown (int) – Pause between retries (seconds)
• ignore_result (bool) – If True result will be saved in result backend
• broker_options – Specific broker options. See NatsOptions broker for example
• deserializator (gromozeka.primitives.base.TaskDeserializator) –

registry

scheduler

start()

Start application

stop()

stop_signal(signum)

gromozeka.app.app.get_app()

Returns: Return type:gromozeka.app.Gromozeka

Module contents

class gromozeka.app.Gromozeka

Bases: object

logger

logging.Logger – Class logger

registry

dict of gromozeka.primitives.Task – Task registry

config

gromozeka.config.Config – config object

_broker_adapter

gromozeka.brokers.BrokerAdapter – Broker

_backend_adapter

gromozeka.backends.BackendAdapter – Broker

_scheduler

gromozeka.concurrency.Scheduler – Scheduler

backend_adapter

broker_adapter

config

config_from_dict(conf)

Configure Gromozeka with dict

Examples

conf={'app_prefix':'my_application','broker_reconnect_max_retries':3}
app=Gromozeka().config_from_dict(conf)

Parameters:conf (dict) – config dict Returns:Configured application Return type:gromozeka.Gromozeka

config_from_env()

Configure Gromozeka with environment variables

Examples

app=Gromozeka().config_from_env()

Returns:Configured application Return type:gromozeka.Gromozeka

get_task(id_)

Get task by id

Parameters:id (str) – Unique task identification Returns:registry task Return type:gromozeka.primitives.RegistryTask

is_closing

logger

pid

register(task, broker_point, worker_class=None, max_workers=1, max_retries=0, retry_countdown=0, ignore_result=False, broker_options=None, deserializator=None)

Parameters:

• task (gromozeka.primitives.Task or gromozeka.primitives.RegistryTask) – Task
• broker_point (gromozeka.primitives.BrokerPointType) – Broker entry
• worker_class (gromozeka.concurrency.Worker, optional) – Worker class
• max_workers (int) – How match workers will start
• max_retries (int) – Maximum number of retries, after it will reached task will down
• retry_countdown (int) – Pause between retries (seconds)
• ignore_result (bool) – If True result will be saved in result backend
• broker_options – Specific broker options. See NatsOptions broker for example
• deserializator (gromozeka.primitives.base.TaskDeserializator) –

registry

scheduler

start()

Start application

stop()

stop_signal(signum)

gromozeka.app.get_app()

Returns: Return type:gromozeka.app.Gromozeka