Commit Graph

1236 Commits (4875331b60ddf8ddfe5b374ec75c938eb9749602)
 

Author SHA1 Message Date
liangsijian 4875331b60 Optimize job.dependency
job.refresh has been call in job.fetch
Selwin Ong 8ebebc9f7c Merge pull request from yaniv-g/extract_move_to_failed_queue
Expose move_to_failed_queue from Worker
Yaniv Greenberg 7dc5d4a936 local commit to avoid circular imports.
Yaniv Greenberg 2da4ccd48d Moved move_to_failed_queue to separate file.
Selwin Ong d71a6c2ece Merge pull request from yaniv-g/master
Expand timeout string feature to both result_ttl and ttl, and add days possibility.
Selwin Ong a3e1ba9450 Merge pull request from fate0/master
fix uncaught StopRequested during send heartbeat
fate0 1ebf880402 fix uncaught StopRequested during send heartbeat
Yaniv Greenberg b49e039d63 Separate move_to_failed_queue from the worker to allow it's use in cli exception handler.
Yaniv Greenberg 39e43207a6 * Added support to use strings to specify both result_ttl and ttl.
* Added Days as possible timeout string (as 'd')
Selwin Ong fbe4cafe2a Updated changelog and tag v0.8.
Alexey Katichev a0113c83cf introduce job.update_meta() to store updated meta to Redis ()
* introduce job.update_meta() to store updated meta to Redis

This closes 

* rename update_meta to save_meta
Selwin Ong fe84828d72 Bump up version to 0.8.0 and updated changelog.
Selwin Ong dc45ab8799 Worker.find_by_key should use hmget instead of repeated hget calls. ()
luojiebin cd529d0ce1 Fixed issue#72 ()
* 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
Aarni Koskela 92cf6f4696 Add waitpid() return value to workhorse error/log messages ()
* Refactor the inner part of the monitor_work_horse loop into a separate function

* Add waitpid() return value to workhorse error/log messages
Peng Liu b7d4b4ec1b Solve the UnicodeDecodeError while decode literal things. ()
* 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.
Felipe Lacerda cab89254b5 Make `Queue.enqueue_job()` execute immediately if `async=False` ()
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.
strawposter 1029adaf1b add sentinel support ()
* add sentinel support

* add sentinel support

* add comment
Selwin Ong 9c0130fe81 Merge pull request from peter-featherstone/patch-1
Minor spelling mistake
Peter Featherstone a99d79187b Minor spelling mistake
Minor spelling update of `proccess` to `process`
Selwin Ong 5660f925ae Merge pull request from friedcell/master
Better support for async job payloads
Selwin Ong f6b4c286c9 Merge pull request from jaywink/fix-unicode-decode-error
Fix UnicodeDecodeError when failing jobs
Selwin Ong 518e4d1726 Merge pull request from selwin/job-deletion-improvements
job.delete() should clean itself from FailedQueue and other job registries
Selwin Ong f760fcb20f job.delete() should cleans itself from FailedQueue and various registries.
Selwin Ong 684281fbf7 Merge pull request from SylvainDe/master
Add most recent Python versions in Travis CI
Sylvain ce89b563eb Remove versions
Selwin Ong 21c1e04593 Merge pull request from samuelcolvin/heroku-fix
correct heroku worker exit logic
Samuel Colvin fd9babe8ce correct heroku worker exit logic
as per @Chronial's comment on b4b99f3
Sylvain b504e197d5 Add most recent Python versions in Travis CI
Add more recent Python versions including development branches and nightly build.
Selwin Ong 2dd923c718 Merge pull request from davidthewatson/patch-1
Fix pip install from HEAD of origin/master
david watson 2d7e1c43f0 Fix pip install from HEAD of origin/master
The pip install -e directions didn't work. This does.
Marko Mrdjenovic c8a955fbb1 Merge commit '83007b20740a97f085a14d3840d1e434350c6600'
# Conflicts:
#	rq/queue.py
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 
Selwin Ong 83007b2074 Merge pull request from jezdez/backend-class-overrides
Allow passing backend classes from CLI and other APIs
Selwin Ong e0be02653e Merge pull request from zyegfryed/master
Use HTTPTransport transport so sentry reporting works by default
Selwin Ong e531cd05fe Merge pull request from WeatherGod/dont_clobber_jobinfo
Trigger a refresh after job execution
Marko Mrdjenovic 35fb6b0b9a move actual execute to a separate method to make it easier to run async jobs
Marko Mrdjenovic 3da3eab11d moved job run to separate method to make async jobs easier
Benjamin Root efb30b45a3 Take a different tack, and enable the exclusion of meta from saves
Benjamin Root 30a7ab4899 Add similar test for when the job fails
Benjamin Root f68aeff481 Added integration test for the metadata persistence feature
Benjamin Root 56c89c1334 Trigger a refresh after job execution
* Prevents clobbering of user-supplied metadata
  modified during the job execution
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
Jannis Leidel 27e4f3a768
Small refactor to simplify registry key setup.
Selwin Ong b241d50c10 Merge pull request from samuelcolvin/heroku-warm-shutdown-fix
allow for already dead horse on heroku worker termination
Selwin Ong eaa350443c Merge pull request from Atala/set_sentry_transport
fix: set HTTP transport as default for sentry
Atala 544f985d41 fix: set HTTP transport as default for sentry
Samuel Colvin 763a304ec6 cope with python 2.6 yawwwwwwn
Samuel Colvin f50bdb31bf skip test_run_scheduled_access_self on pypy
Samuel Colvin b4b99f30b0 allow for already dead horse on heroku worker termination