| Commit message (Collapse) | Author | Age | Files | Lines |
|---|
| |
|
|
|
|
|
|
|
|
|
| |
- allow optional support for running the scheduler without a redis
backend for persistent schedule storage. The default is to exit on
startup error. The user can set `redis_startup_error_hard_kill` to
false if they really want to run the scheduler with no backend db.
- allow users the ability to specify a redis client class. this will let
them use redis-cluster if they wish. They can install the appropriate
module and define `redis_client_class` (and if necessary class keyword
arguments via `redis_client_class_kwargs`).
|
| | |
|
| | |
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
This adds 2 new config options: `job_entry_func` and `job_exit_func`.
These functions are executed before and after every single job
execution. The rationale behind this is before and after each request
Django cleans up stale database connections, so Django jobs need some
way of running this same setup/cleanup functions.
https://github.com/django/django/blob/master/django/db/__init__.py#L57
```
# Register an event to reset transaction state and close connections past
# their lifetime.
def close_old_connections(**kwargs):
for conn in connections.all():
conn.close_if_unusable_or_obsolete()
signals.request_started.connect(close_old_connections)
signals.request_finished.connect(close_old_connections)
```
fixes: #41
|
| | |
|
| |
|
|
| |
- starts emq-cli and implements status for the router
|
| | |
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
- Rename `WORKERS` setting to `CONCURRENT_JOBS` for more clarity. Added this
setting to the command line options, the ini .conf & default settings conf.py
files.
- Added support for JSON style arrays in INI config.
- Added support for weighted named queues. The style for the setting is
[[weight, "name"], [weight, "name"]]. Configured in both the INI and command
line for job manager. Added documentation.
- Updated the spec for the INFORM message. Weights are sent with the queue
names. If there are no weights specified they will be given the default value
of 0.
- updated Router.queues to a list from a deque so that it can be sorted
by priority more easily.
|
| | |
|
| |
|
