You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
Ruslan Mullakhmetov ed264f08bb
feat: added job heartbeat to track whether job is actually executing (#1349)
* feat: added job heartbeat to track whether job is actually executing

heartbeat might be needed in cases when worker was hardkilled or the whole VM/docker was forcibly rebooted.

* fixed tests

* fixed test coverage issue

* chore: renamed job.heartbeat stuff according to review feedback

* chore: pipelined worker heartbeat and job heartbeat

* docs: documented job.heartbeat property

* fixes after review

* docs: updated last_heartbeat description

* chore: review

Co-authored-by: Ruslan Mullakhmetov <ruslan@twentythree.net>
4 years ago
..
cli Add entry ssl_ca_certs in worker config settings (#1347) 4 years ago
compat Add redis_server_version to worker/job/queue (#1286) 5 years ago
contrib Add sentry_debug and sentry_ca_certs params (#1229) 5 years ago
__init__.py Job retry feature. Docs WIP (#1299) 4 years ago
command.py Workers can listen to external commands via pubsub (#1363) 4 years ago
connections.py modify zadd calls for redis-py 3.0 (#1016) 6 years ago
decorators.py Allow retries to be set through decorator (#1319) 4 years ago
defaults.py RQ v1.0! (#1059) 6 years ago
dummy.py Enable the most modern Python syntax. 11 years ago
exceptions.py Implement Customizable Serializer Support (#1219) 5 years ago
job.py feat: added job heartbeat to track whether job is actually executing (#1349) 4 years ago
local.py Ignore flake8 checks in local.py 9 years ago
logutils.py log messages < error is now output to stdout instead of stderr (#1312) 4 years ago
queue.py pass retry param to enqueue_at func (#1343) 4 years ago
registry.py scheduler: now operates with chunks of jobs (#1355) 4 years ago
scheduler.py Increase scheduler lock TTL to 60 (#1362) 4 years ago
serializers.py Use pickle.HIGHEST_PROTOCOL by default (#1254) 5 years ago
suspension.py Fixed #812 - Send heartbeat during suspension check 7 years ago
timeouts.py Pass job_id to death penalty class (#936) 6 years ago
utils.py fix deprecated Iterable import (#1329) 4 years ago
version.py Bump version to 1.5.2 4 years ago
worker.py feat: added job heartbeat to track whether job is actually executing (#1349) 4 years ago
worker_registration.py RQ v1.0! (#1059) 6 years ago