util
/
rq
mirror of https://github.com/peter4431/rq.git
3
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
1,353 Commits
2 Branches
0 Tags
3.3 MiB
main
master
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from '7eb95bf405'
${ noResults }
Commit Graph

869 Commits (7eb95bf405fe034ef416c7b3519bf12c713e97dd)

Author SHA1 Message Date
Selwin Ong 94dfb943b1 Merge pull request #690 from liorsbg/master 
Fix for Issue #644
 9 years ago
liorsbg 4c5d04105a Fix for #644 9 years ago
Selwin Ong cd0414361c Merge pull request #687 from jlopex/javi/allow_quiet_worker_class 
Allow Worker work method to specify the log verbosity
 9 years ago
Javier Lopez 43cb51064a Allow Worker work method to specify the log verbosity 9 years ago
Chris Curvey 4326e19140 have worker use the passed-in connection if provided 9 years ago
zfz c2374c8035 Correct the comment of job's requeue function. 9 years ago
zfz 0492eaef01 Fix the mistypo of logger str for procline. 9 years ago
Selwin Ong 8158a180f3 Merge pull request #666 from redbaron4/python_2_6_log 
Fix logging regression for Python-2.6
 9 years ago
Selwin Ong af0b19e707 Merge pull request #642 from butla/master 
Worker only creates log handlers if there aren't any.
 9 years ago
Dheeraj 0a49e247ea Fix logging regression for Python-2.6 
logger.setLevel() doesn't work when a string is passed in Python-2.6.
This patch checks if the level has been set and if not (in Python-2.6),
tries to set it again using appropriate level constants
Also unused dictConfig import is removed
 9 years ago
Selwin Ong e1e4c00a67 Merge pull request #659 from javimb/javimb/decorator-ttl 
Add ttl argument to decorator
 9 years ago
Antoine Leclair 81679a35d9 Merge branch 'master' into custom-queue-class 
Conflicts:
	tests/test_worker.py
 9 years ago
VicarEscaped 01bd0cebd6 Update job status with set_status 9 years ago
Javi Imbernon 1d6c2b98b7 Add ttl argument to decorator 9 years ago
Antoine Leclair 05ed85804c Worker accepts custom queue class 9 years ago
Selwin Ong 640b2e31a0 Merge pull request #633 from olingerc/warmshutdown 
Save date on which a busy worker receives a warm shutdown request
 9 years ago
orangain e8165fdddf Accept byte strings as the first argument of Worker() in Python 2 
This make it easy to write Python 2/3 compatible code.
e.g.

    Worker(sys.argv[1:])

    # Without from __future__ import unicode_literals
    Worker(['high', 'normal', 'low'])
 9 years ago
Michal Bultrowicz fe122ac799 Worker only creates log handlers if there aren't any. 10 years ago
Eduard Carreras c27a6434a8 Set job as finished when not working in async mode 10 years ago
Nick Snell 0e532f3ec4 Correction to worker command, cast results-ttl to int 10 years ago
Christophe Olinger 2be468a404 - Rename paramter both in redis and python to shutdown_requested_date 
- Use connection instead of pipeline
 10 years ago
Christophe Olinger ae27ce9871 Merge branch 'master' into warmshutdown 10 years ago
Christophe Olinger 3e586bd6d6 Add remove current_job based on the correct upstream master branch 10 years ago
Christophe Olinger d622f47aff Save date in redis on which worker receives a warm shutdown request while busy 10 years ago
Selwin Ong 2485334100 Merge pull request #609 from tornstrom/master 
Allow meta when enqueing
 10 years ago
SkyLothar 70b5554566 make sure exc_info is text type 10 years ago
SkyLothar f9978bc27c make sure state text_type 10 years ago
Tornstrom 50a114a0a8 Allow meta when enqueing 10 years ago
Selwin Ong 45addbcaf2 Deleted job.set_started_at_now. 10 years ago
Selwin Ong 364919c7c8 Moved job.hset_value to connection._hset. 10 years ago
Selwin Ong 961e443611 Merge pull request #619 from foxx/patch-1 
Fixes #613
 10 years ago
Selwin Ong 5afd1a90e5 Merge pull request #589 from samuelcolvin/job-started_at 
add job.started_at
 10 years ago
Samuel Colvin 6fc34dc6a6 moving started_at to prepare_job_execution 10 years ago
Cal Leeming d80f9f8ba0 Fixes #613 
This has been discussed in #514, #282 and #88.

Using an explicit type check via `isinstance`, rather than duck typing, is typically considered unpythonic and breaks compatibility with mock objects such as FakeRedis. This patches removes the type check, and instead looks for a common method that should be present on the object as a hint on whether it's compatible or not.
 10 years ago
Selwin Ong 8bbd833855 Merge pull request #600 from glaslos/cancel_remove 
Cancel and Delete differences
 10 years ago
Selwin Ong 702dfd2c31 Merge pull request #611 from ahxxm/delay-task 
depreciation fixes
 10 years ago
Michael Keirnan 14723ecc1f Merge remote-tracking branch 'upstream/master' 10 years ago
ahxxm b06f112cb0 fix tests 
syntax: assertEquals -> assertEqual, assertNotEquals -> assertNotEqual
usage: status of worker and job now will use get/set method instead of property method
 10 years ago
Selwin Ong 91177b7317 Merge pull request #601 from glaslos/registry_cleanup_log_msg 
log.info added when cleaning registries
 10 years ago
glaslos a424d320a8 log.info added when cleaning registries 10 years ago
Karoly Frendrich ca069e5112 rqinfo config parameter 10 years ago
glaslos 0a6df13d9d delete dependents and delete in cleanup. Fixed tests. 10 years ago
glaslos d2eeb3b3db job.cancel before delete and doc string fixes 10 years ago
glaslos 02844034d7 Merge branch 'master' into cancel_remove 10 years ago
glaslos 5a3bebf85b only remove from queue on job.cancel 10 years ago
horida 04987a80da mark as busy before forking horse 10 years ago
Selwin Ong 95f740299a Merge pull request #588 from samuelcolvin/logging-extras 
more info in 'Job OK' log entry
 10 years ago
Samuel Colvin 082e61a212 add job.started_at 10 years ago
Samuel Colvin 30c29614c6 more info in 'Job OK' log entry 10 years ago
Samuel Colvin e750134e8a move request_(force_)stop out of _install_signal_handlers 10 years ago
Vincent Driessen ca235aee19 This is 0.5.6 10 years ago
Selwin Ong 544f2e6fb2 Fixed result logging call . 10 years ago
Selwin Ong 2140cc4fab Job result should be converted to text before being logged. 10 years ago
Selwin Ong bb4336f612 Merge pull request #578 from tbaugis/master 
log job result in DEBUG level and truncate to 2k symbols
 10 years ago
Toms Bauģis 5a4f297134 do not truncate result output as that can be done in the log formatter 10 years ago
Michael Keirnan da7d59e1a9 Merge remote-tracking branch 'upstream/master' 
* upstream/master:
  Modified patch_connection to allow Redis connection to be easily mocked.
 10 years ago
Michael Keirnan bad054989d export worker id and job id to env of work horse 
For tracing job execution in a distributed system it is useful to tag log
entries with the worker id and job id. The current job is accessible
via get_current_job(), but that requires an extra redis connection. And
the current worker id (the worker id of the parent process) does not appear
to be available.

Rather than introducing an `rqworker` alternative or subclassing Worker, it
feels simple and efficient to make these contextual ids available as
environment variables. This should have no performance cost and no
API compatibility issues.

Some useful things to do with these values in the worker horse process:

+ include them in log messages
+ include them as 'x-' headers in HTTP requests made by workers
 10 years ago
Selwin Ong e538512c79 Merge branch 'master' of github.com:nvie/rq 
Conflicts:
	tests/test_job.py
 10 years ago
Selwin Ong 0e4112da7a Modified patch_connection to allow Redis connection to be easily mocked. 10 years ago
Toms Bauģis ade154575e fix travis error - python 2.6 or whatevs wants positions spelled out for .format 10 years ago
Selwin Ong 1a089887c0 Merge pull request #564 from jlopex/javi/fix_dependent_jobs_on_different_queues 
support multiple queues on dependent jobs
 10 years ago
Toms Bauģis 682d4adb40 log result in DEBUG level and truncate to 2k symbols 10 years ago
Javier Lopez d3d9a20680 Do not call pipeline.execute() if pipeline is given as argument 10 years ago
Selwin Ong cf20f1d9b2 Merge pull request #576 from jlopex/ensure_custom_handlers_are_called 
Ensure custom exception handlers call when Redis is down
 10 years ago
Vincent Driessen 02c6df6a45 This is 0.5.5 10 years ago
Vincent Driessen c1a4780d10 Fix PEP8 complaints 10 years ago
Javier Lopez 4fb59a4ceb Ensure custom exception handlers calls when Redis is down 10 years ago
Javier Lopez 8a6bc08e47 Added pipeline named argument to enqueue_job 10 years ago
Javier Lopez b4f157516e enqueue_dependents now uses origin queue to enqueue 
Current implementation is using the first job queue
to insert the dependent jobs. This makes RQ to ignore
the original queue where the jobs were enqueued.

With this change, we will use job origin attribute to
fetch the original queue, then insert the dependent
job to the fetched queue.

fixes issue #512
 10 years ago
Selwin Ong e6a15c57b3 Disable click >= 5.0's unicode_literals warnings. 10 years ago
Selwin Ong f09be523dd Merge pull request #573 from jcsaaddupuy/feature/dequeue_any_not_recursive 
dequeue_any not recursive
 10 years ago
Jean-Christophe SAAD-DUPUY 8fbf5452fa fix: return (None, None) for dequeue_any if no result 10 years ago
Jean-Christophe SAAD-DUPUY 59d193590c fix: remove recursive call to dequeue_any 10 years ago
Damnever 43616ea696 _Colorizer().notty is more clear 10 years ago
Dustin Falgout 91a3aa7493 make args and kwargs explicit for enqueue_call function 
closes #466
 10 years ago
likeon fc4124e39c Fixes Job.__eq__ crash when other object doesn't have id attribute 10 years ago
Selwin Ong e6a499ada8 Merge pull request #561 from selwin/async-bug 
Sync jobs should be cleaned up after execution.
 10 years ago
Selwin Ong edd139d86f Sync jobs should be cleaned up after execution. 10 years ago
Selwin Ong cdcea84105 Merge pull request #557 from selwin/exception_handling 
Exception handling
 10 years ago
Vincent Driessen e88525a649 This is 0.5.4 10 years ago
Vincent Driessen 28a19ee717 Remove warning that's now breaking since the Raven API changed 10 years ago
Selwin Ong 3c3646cf91 Merge branch 'master' into exception_handling 
Conflicts:
	tests/fixtures.py
 10 years ago
Selwin Ong 8bfbeac67d Running rqworker without specifiying --exception-handler shouldn't override default behavior. 10 years ago
mozillazg 7198b4568a Fixed a format error 10 years ago
Vincent Driessen 0de225ec62 Emphasize private nature of `stopped` property 10 years ago
Vincent Driessen ec0e04727b Rename `maintenance_date` -> `last_cleaned_at` 10 years ago
Vincent Driessen 891be55b87 Clean up Worker.__init__ logic a little 10 years ago
Vincent Driessen 4d0ae5da98 Clean up type checking of Worker constructor 10 years ago
Vincent Driessen 94258761ae Make string formatting consistent 10 years ago
Selwin Ong 8f9c507f12 Bump version to 0.5.3. 10 years ago
Marcus Martins 513f6310d2 Change default TTL to None insted of -1 10 years ago
Marcus Martins 5b8726ad2d Fixes #502 
Fixes some broken tests and misbehaviour with ttls. There was a temporal
coupling between saving the job and setting its expires parameter.
 10 years ago
Selwin Ong f370f79819 Merge pull request #534 from selwin/registry-maintenance 
Worker automatically cleans job registries every hour
 10 years ago
Neal Todd bac6699ea4 Allow non-ASCII characters in keyword arguments. 10 years ago
Selwin Ong c3767e28e2 Worker now runs maintenance tasks every hour and on startup. 10 years ago
Selwin Ong 5782ac10c4 Added worker.clean_registries(). 10 years ago
Selwin Ong faf9d3e668 Added clean_registries(queue) function to clean job registries related to that queue. 10 years ago
RyanMTB 9a00b0eca6 Updated Worker API 10 years ago
Selwin Ong d51f0200d7 Merge pull request #513 from trevorprater/master 
Improving logging.
 10 years ago
Selwin Ong 70d5f971bd Jobs from FinishedJobRegistry that are moved to FailedQueue should have "failed" as status. 10 years ago
Cosmin Stefan 260f7caf66 Enable proper setup of signale handlers for SimpleWorker as well. fixes #523 
This allows a SIGTERM to make the worker perform a warm shutdown and cleanly break out of the loop and finish the current job, if any.
 10 years ago
Vincent Driessen 8f7322ed10 This is 0.5.2 10 years ago
Trevor Prater 5674edad61 Changed rqworker shutdown message. 
- As requested by @nvie and @selwin.
 10 years ago
Trevor Prater fd1dca40b9 Improving logging. 
- Include worker key in worker startup log statement.
- Added a notification to make it more clear when a 'burst' worker dies.
 10 years ago
Selwin Ong cff6fbff41 Merge pull request #477 from glaslos/ttl_tests_fixes 
TTL tests and fixes
 10 years ago
glaslos 071c47dacb hard-coded TTL to -1 on job.perform() 
Removed merge artifacts
 10 years ago
Serhii Maltsev 91f263d8e0 change try/except in python2/3 compatibility to to_text() 10 years ago
Tamir Duberstein 985a2664a4 Prevent `Queue#dequeue` from blowing the stack 
In the case of many sequential jobs having been deleted, a recursive
implementation of `Queue#dequeue` is prone to blowing the stack in the
absence of tail-recursion support. Change the implementation from
recursive to iterative to work around this issue in CPython.
 10 years ago
Vincent Driessen 5cb873b438 Fix PEP8 complaint. 10 years ago
Vincent Driessen cd155299a4 Fix PEP8 complaint. 10 years ago
Vincent Driessen 6c6e53542f Don't require redis-py 2.10 just for the SSL option. 10 years ago
Vincent Driessen 8505198298 Bump to 0.5.1. 10 years ago
Vincent Driessen 5990fa9d73 Merge pull request #499 from vladkens/issue/498 
ZADD bugfix
 10 years ago
Eric Bustarret 9fba806662 Add REDIS_SSL option 
Allow the worker to connect to a Redis instance through SSL (ex: Azure
Redis Cache use SSL only by default)
 10 years ago
Vlad Pronsky 933e6697cd Fixed redis drivers bug 10 years ago
glaslos 3d4d6a86d5 persist the job right before execution 10 years ago
glaslos 24d5e08992 Merge branch 'master' into ttl_tests_fixes 
Conflicts:
	tests/test_job.py
 10 years ago
Selwin Ong 30b21ef06e Merge pull request #465 from marklap/workerbirthdeath 
add birth_date and death_date properties to Worker
 10 years ago
Mark LaPerriere 636a537fa7 updates addressing @selwin comments for PR #465 10 years ago
Taras Semenenko 3dfd044767 Add missed `multi` command after `watch` 
`watch` command should be used in conjunction with `multi` command
which was missed in enqueuing of job with dependencies.
Fix #487
 10 years ago
Bradley Young 04e403e1a3 dread comma, I adjure thee. 10 years ago
Bradley Young d56b5424c8 merging master and fixing conflicts 10 years ago
Bradley Young c428f955e4 per @selwin, adding a deprecated handler for exc_handler 10 years ago
alternativshik 219f21b637 Allow non-ASCII characters in arguments 
get_call_string() failed if any arguments contained non-ASCII strings.

Fixes #406
 10 years ago
Selwin Ong 1005222371 Restored the ability to specify connection params in config 10 years ago
glaslos c155918d6d lrem only first occurrence of the job id (we expect only one) 10 years ago
Mark LaPerriere a4ca4704ac convert redis returned bytes into text/string 10 years ago
Mark LaPerriere cfe3da287a updated branch to latest 10 years ago
Vincent Driessen b8d425b318 Various PEP8 fixes. 10 years ago
Vincent Driessen fac2b10309 Auto-sort imports using isort. 10 years ago
Vincent Driessen e8c3b96a5a Bump to 0.5.0. 10 years ago
glaslos 703ab0e355 removed merged comment 10 years ago
glaslos 646f1cda22 Merge branch 'master' into ttl_tests_fixes 
Conflicts:
	rq/queue.py
 10 years ago
glaslos 5b5ab4860f passing on the ttl 10 years ago
Bradley Young f05d77b92b changing "default" for exception_handlers to None; same exact logic can be implemented, but cleaner 10 years ago
Bradley Young d3e4fb567b merge && updates to add multiple exception handlers. 10 years ago
Bradley Young f575137612 updating worker to have exception_handlers 10 years ago
Selwin Ong dac0be6cc7 Added DeferredJobsRegistry to keep track of deferred jobs. 10 years ago
Selwin Ong 3e674fbe6a queue.enqueue() should set job.origin. 10 years ago
Selwin Ong 9320496402 Simplify FailedQueue.quarantine and ensure that a deferred job's status is set to Queued when enqueued. 10 years ago
Selwin Ong 7fd2ac8ca6 Added "DEFERRED" Job status for jobs that have unsatisfied dependencies. 10 years ago
Vincent Driessen dc5cd514ee Explicitly cast map() result to a list, for Python 3 compat. 10 years ago
Selwin Ong dc09676ee0 Minor copywriting fixes. 10 years ago
Selwin Ong 01ab2f20dd Minor copywriting fixes. 10 years ago
Vincent Driessen 543bcbc60b Explicitly cast map() result to a list, for Python 3 compat. 10 years ago
Selwin Ong eae2c40ea0 Merge pull request #457 from jlopex/block_until_horse_finishes 
Make parent worker process wait until horse process finishes
 11 years ago
Selwin Ong 0a0a81da6d Merge pull request #463 from conslo/skip-queue 
Skip queue
 11 years ago
Mark LaPerriere e6c32edad9 add birth_date and death_date properties to Worker 11 years ago
Jonathan Tushman 1ae5a12a81 merging master 11 years ago
Jonathan Tushman ccd41396f6 adding suspend with duration test 11 years ago
Travis Johnson add4d625b6 Merge branch 'nvie' into skip-queue 
Conflicts:
	rq/queue.py
 11 years ago
Vincent Driessen cd0c3c9c1e Merge pull request #462 from conslo/worker-hash 
Worker hash
 11 years ago
Jonathan Tushman 82333d2ad5 triggering shutdown by setting a redis flag 11 years ago
Travis Johnson db75958ad2 use 'at_front' instead of 'skip_queue' 11 years ago
Selwin Ong e1801c5c44 Merge pull request #453 from glaslos/job_ttl 
TTL for jobs
 11 years ago
Travis Johnson ac61f502a1 skip_queue functionality 11 years ago
Travis Johnson f60e4884df a comment typo 11 years ago
Travis Johnson 0ad4cb3410 comments 11 years ago
Travis Johnson c301369c2e implement __eq__ and __hash__ for workers 11 years ago
Nic Cope 09cab7a90d Allow maximum job age to be specified when cleaning up or getting expired jobs from a registry. 
This ensures that all jobs cleaned from a started registry end up in the failed queue.
 11 years ago
Javier Lopez fc5295edfc Set busy state on parent while waiting for horse 11 years ago
Nic Cope 6ab7070a92 Rename registry timeout to registry ttl 
This matches job.cleanup() better and (I think) makes the purpose slightly clearer.
 11 years ago
Nic Cope 9f699d758d Any negative number should cause a job to live forever in a registry. 
While the documentation explicitly mentions ttl=-1, this matches better the behaviour of the job.cleanup() method.
 11 years ago
glaslos c6a83eaa82 calling self.cleanup to set job expiration 11 years ago
glaslos 8a3fd91e2e renaming job.job_ttl to job.ttl 11 years ago
Selwin Ong 2091c601b1 Merge pull request #451 from conslo/depend-on-unsaved-job-ids 
Depend on unsaved job ids
 11 years ago
Nic Cope 8fa184b86b Ensure the FinishedJobRegistry honors an 'infinite' result_ttl of -1 11 years ago
glaslos 55c541bc59 added job ttl to queue.enqueue() 11 years ago
Travis Johnson af4b0436c1 instantiate a job instead of fetch 
this removes the need for the depended on job.id already being saved
 11 years ago
Travis Johnson 14d1186241 use internal job_class for check 11 years ago
Bradley Young 5caccaabfe Adding optional list handling to the exc_handler option in Worker. 
Adding command line --exception_handler option (with multiple entries allowed) to `rq worker`
Added tests for command line options.
 11 years ago
Travis Johnson 3467868f1f allow depends_on to be a job id or a job itself 
Other parts of the code (i.e.: the `.create()` method) allow the `depends_on` kwarg to be a `Job` object *or* a job id. This is an attempt to allow that same idea within the `.enqueue_call()` method for a queue. Since this part of the code requires actually knowing the precise redis key for the job that's depended on, my intuition is that a `.fetch()` is the only way to solve this.
 11 years ago
Selwin Ong 0dbe68527c Merge pull request #431 from negz/worker-redis-bug 
Pass the default worker connection into the started and finished registries
 11 years ago
Adam Wen f5001a0e36 fix decode error in py3. 11 years ago
Adam Wen 1795e1ee53 fix decode 11 years ago
Adam Wen cd0230cae3 make job description unicode friendly 11 years ago
Nic Cope de0b501823 Pass the default worker connection into the started and finished registries 
In practice all the registry methods are called with pipelines, but if no
connection is passed in when instantiating the registry and the connection
stack is empty resolve_connection will raise NoRedisConnectionException.
 11 years ago
zhangliyong 6621105bde Use type instead of default to specify interval option type 11 years ago
zhangliyong 3d49784bcc Merge branch 'master' of github.com:nvie/rq into cli-rq-worker 11 years ago
Selwin Ong 2307bc8253 Added FinishedJobRegistry to monitor finished jobs. 11 years ago
Selwin Ong 74a9982ecb Fixed a bug where expired jobs aren't deleted from JobStartedRegistry. 11 years ago
Selwin Ong 18c6ea64ef Merge pull request #419 from selwin/registry-len 
Added JobStartedRegistry.count
 11 years ago
zhangliyong f9511664c8 Make flake8 happy :) 11 years ago
zhangliyong 1b39996bf7 Make pep8 11 years ago
zhangliyong c6033b312e Cleanup 11 years ago
zhangliyong 6510bb46f3 Fix interval type bug, it should be float 11 years ago
zhangliyong 21c14c0e21 Cleanup 11 years ago
zhangliyong 4d91f136f8 Move redis url default value to connect function 
So worker subcommand can retrieve redis url from config file if url
option value is None, otherwise url option value will never be None.
 11 years ago
zhangliyong 4df076f3aa Retrieve url from config file 11 years ago
zhangliyong 229a00fee5 Cleanup 11 years ago
zhangliyong 88fe5124d8 Make pythonic 11 years ago
zhangliyong 907e71dc86 Make pythonic 11 years ago
zhangliyong f10c749b7c Use click's evvar to retrieve SENTRY_DSN environment value 11 years ago
zhangliyong 842f27294a Convert rqworker to 'rq worker' subcommand 11 years ago
zhangliyong 7b434a32eb Let cleanup_ghosts accept conn argument 11 years ago
Selwin Ong 202be75b21 Merge pull request #415 from foxx/feature/custom-job-ids 
Allow job ID to be set on enqueue/enqueue_call() - fixes #412
 11 years ago
Selwin Ong c1dc30eae3 Added __len__ method to Queue. 11 years ago
Selwin Ong fae7df5aa7 Renamed StartedJobRegistry.get_job_count to StartedJobRegistry.count for consistency. 11 years ago
Selwin Ong 41ae1ce8a7 Added a registry.get_job_count(). 11 years ago
foxx 30ea76ddd6 Fixed silly typo 11 years ago