jhorman
/ gevent_rqworker.py
Last active
January 27, 2023 13:52
— forked from lechup/gevent_rqworker.py
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| from __future__ import absolute_import | |
| import signal | |
| import gevent | |
| import gevent.pool | |
| from rq import Worker | |
| from rq.timeouts import BaseDeathPenalty, JobTimeoutException | |
| from rq.worker import StopRequested, green, blue | |
| from rq.exceptions import DequeueTimeout |
lechup
/ gevent_rqworker.py
Last active
January 27, 2023 13:52
GeventWorker class to use with rq. All credits to https://github.com/jhorman from https://github.com/nvie/rq/issues/303#issuecomment-45304465 comment.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| from __future__ import absolute_import | |
| import signal | |
| import gevent | |
| import gevent.pool | |
| from rq import Worker | |
| from rq.timeouts import BaseDeathPenalty, JobTimeoutException | |
| from rq.worker import StopRequested, green, blue | |
| from rq.exceptions import DequeueTimeout |