gromozeka.app package¶
Submodules¶
gromozeka.app.app module¶
-
class
gromozeka.app.app.
Gromozeka
¶ Bases:
object
-
logger
¶ logging.Logger
– Class logger
-
registry
¶ dict
ofgromozeka.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
orgromozeka.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) –
- task (
-
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
ofgromozeka.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
orgromozeka.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) –
- task (
-
registry
-
scheduler
¶
-
start
()¶ Start application
-
stop
()¶
-
stop_signal
(signum)¶
-
-
gromozeka.app.
get_app
()¶ Returns: Return type: gromozeka.app.Gromozeka