Selwin Ong
2bc2f447d3
Merge pull request #841 from strawposter/master
...
accept multiple path
9 years ago
Selwin Ong
3666f4987e
Merge pull request #855 from floqqi/master
...
Windows: Use SIGTERM instead of SIGKILL
9 years ago
Selwin Ong
5f5e113790
Merge pull request #831 from katichev/explicit_cleanup
...
Replace job id with job instance in the job stack. Remove implicit "cleanup" call from "job.save"
9 years ago
Selwin Ong
165b7ae6b9
Merge pull request #845 from liangsijian/master
...
use enum WorkerStatus instead of str
9 years ago
Florian
61f27215b3
Windows: Use SIGTERM instead of SIGKILL
9 years ago
Amjith Ramanujam
3cf5850afc
Honor the job_class for failed_queue.
9 years ago
liangsijian
4556f39c34
use enum WorkerStatus instead of str
9 years ago
liangsijian
4875331b60
Optimize job.dependency
...
job.refresh has been call in job.fetch
9 years ago
Alexey Katichev
09697e567f
revert back job.cleanup changes
9 years ago
kirill
f2ff1b05f7
accept multiple path
9 years ago
Selwin Ong
8ebebc9f7c
Merge pull request #833 from yaniv-g/extract_move_to_failed_queue
...
Expose move_to_failed_queue from Worker
9 years ago
Yaniv Greenberg
7dc5d4a936
local commit to avoid circular imports.
9 years ago
Yaniv Greenberg
2da4ccd48d
Moved move_to_failed_queue to separate file.
9 years ago
Selwin Ong
d71a6c2ece
Merge pull request #832 from yaniv-g/master
...
Expand timeout string feature to both result_ttl and ttl, and add days possibility.
9 years ago
fate0
1ebf880402
fix uncaught StopRequested during send heartbeat
9 years ago
Yaniv Greenberg
b49e039d63
Separate move_to_failed_queue from the worker to allow it's use in cli exception handler.
9 years ago
Yaniv Greenberg
39e43207a6
* Added support to use strings to specify both result_ttl and ttl.
...
* Added Days as possible timeout string (as 'd')
9 years ago
Alexey Katichev
b7d50cedc4
replace job.id with job instance in local _job_stack
9 years ago
Alexey Katichev
3596449cc0
remove implicit cleanup call from job.save
9 years ago
Alexey Katichev
a0113c83cf
introduce job.update_meta() to store updated meta to Redis ( #823 )
...
* introduce job.update_meta() to store updated meta to Redis
This closes nvie/rq#811
* rename update_meta to save_meta
9 years ago
Selwin Ong
fe84828d72
Bump up version to 0.8.0 and updated changelog.
9 years ago
Selwin Ong
dc45ab8799
Worker.find_by_key should use hmget instead of repeated hget calls. ( #826 )
9 years ago
luojiebin
cd529d0ce1
Fixed issue#72 ( #818 )
...
* Added a custom exception for timeout transfer
* Added a util to transfer timeout to a united format
* Transfer timeout format when creating a queue or enqueue jobs
* Fixed typos
* Fixed bug in transfer_timeout function
* Added test for function transfer_timeout
* Updated transfer_timeout to allow uppercase unit
* Renamed function in utils
9 years ago
Aarni Koskela
92cf6f4696
Add waitpid() return value to workhorse error/log messages ( #819 )
...
* Refactor the inner part of the monitor_work_horse loop into a separate function
* Add waitpid() return value to workhorse error/log messages
9 years ago
Peng Liu
b7d4b4ec1b
Solve the UnicodeDecodeError while decode literal things. ( #817 )
...
* Solve the UnicodeDecodeError while decode literal things.
* Add test case for when worker result is a unicode or str object that other than
pure ascii content.
9 years ago
Felipe Lacerda
cab89254b5
Make `Queue.enqueue_job()` execute immediately if `async=False` ( #798 )
...
Currently, the job is being performed inside `enqueue_call()`, which
means that `async=False` has no effect if `enqueue_job()` is called
directly. This commit fixes that.
9 years ago
strawposter
1029adaf1b
add sentinel support ( #808 )
...
* add sentinel support
* add sentinel support
* add comment
9 years ago
Peter Featherstone
a99d79187b
Minor spelling mistake
...
Minor spelling update of `proccess` to `process`
9 years ago
Selwin Ong
5660f925ae
Merge pull request #788 from friedcell/master
...
Better support for async job payloads
9 years ago
Selwin Ong
f6b4c286c9
Merge pull request #757 from jaywink/fix-unicode-decode-error
...
Fix UnicodeDecodeError when failing jobs
9 years ago
Selwin Ong
f760fcb20f
job.delete() should cleans itself from FailedQueue and various registries.
9 years ago
Samuel Colvin
fd9babe8ce
correct heroku worker exit logic
...
as per @Chronial's comment on b4b99f3
9 years ago
Marko Mrdjenovic
c8a955fbb1
Merge commit '83007b20740a97f085a14d3840d1e434350c6600'
...
# Conflicts:
# rq/queue.py
9 years ago
Jason Robinson
213969742e
Fix UnicodeDecodeError when failing jobs
...
Worker handle_exception and move_to_failed_queue couldn't handle a situation where the exception raised had non-ascii characters. This caused a UnicodeDecodeError when trying to format the exception strings.
If on Python 2, ensure strings get decoded before building the exception string.
Closes #482
9 years ago
Selwin Ong
83007b2074
Merge pull request #786 from jezdez/backend-class-overrides
...
Allow passing backend classes from CLI and other APIs
9 years ago
Marko Mrdjenovic
35fb6b0b9a
move actual execute to a separate method to make it easier to run async jobs
9 years ago
Marko Mrdjenovic
3da3eab11d
moved job run to separate method to make async jobs easier
9 years ago
Benjamin Root
efb30b45a3
Take a different tack, and enable the exclusion of meta from saves
10 years ago
Benjamin Root
56c89c1334
Trigger a refresh after job execution
...
* Prevents clobbering of user-supplied metadata
modified during the job execution
10 years ago
Jannis Leidel
c019662430
Allow passing backend classes (job, queue, worker, connection) from CLI and other APIs
...
This includes:
- a partial refactor of the CLI to organize the shared options
- extends the tests in areas where passing custom backend classes makes sense
- allow setting the core CLI options as env vars
- minor cosmetic changes here and there
10 years ago
Jannis Leidel
27e4f3a768
Small refactor to simplify registry key setup.
10 years ago
Selwin Ong
b241d50c10
Merge pull request #774 from samuelcolvin/heroku-warm-shutdown-fix
...
allow for already dead horse on heroku worker termination
10 years ago
Atala
544f985d41
fix: set HTTP transport as default for sentry
10 years ago
Samuel Colvin
b4b99f30b0
allow for already dead horse on heroku worker termination
10 years ago
Michael DeWulf
9e8922a099
Don't run lrem directly if we have a pipeline
10 years ago
Selwin Ong
6721463fdf
queue.enqueue_call should call Job.exists with connection parameters.
10 years ago
Selwin Ong
1ae10dd529
Bump version to 0.7.1.
10 years ago
Julien Surloppe
dc3bba9362
Another check on failed status and test
10 years ago
Julien Surloppe
88a3c60177
Fix get job on failed queue
10 years ago
Stefan Hammer
f9bff3d12b
Merge branch 'master' into 739_fix_race_condition
10 years ago