| 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`).
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| |
|
|
|
|
|
|
| |
- adds eventmq.client.jobs.job and Job() to be used as a decorator for
deferring functions
- add example usage to README
- add client env variable `EMQ_BROKER_ADDR` to easily specify where the broker
is for deferring jobs.
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
- 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.
|
|
|
- fixes off-by-one bug when tracking available worker slots
- fixes bug where workers would crash and die if they couldn't import the jobs
- adds zmq errno 65 to fwdmessage for peer gone away when a worker dies suddenly
- set hb to 0 and clean up dead workers before retrying to send message when worker goes away suddenly
- version bump to 0.2.0
|
