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

301 Commits (995554cdd281bceff07d2dc75305670d56a02c40)

Author SHA1 Message Date
Jacob Oscarson 995554cdd2 Removed alternative parameters for PID file creation 12 years ago
Jacob Oscarson 72d219a24c Writes an optional specified PID file on startup 12 years ago
Vincent Driessen 73b7453e40 Fix typo. 12 years ago
Vincent Driessen 2fb6e5ca1a Minor refactoring of the paging logic. 12 years ago
Alex Morega e3075ea6be get a page of jobs 12 years ago
Alex Morega ef0f04bff6 extract `safe_fetch_job` method 12 years ago
Vincent Driessen 0f804e07ae Merge pull request #198 from johannth/scripts-respect-url 
Made rqworker and rqinfo respect db parameters from --url
 12 years ago
Jóhann Þorvaldur Bergþórsson 7660fbdc18 Made rqworker and rqinfo respect db parameters from --url 
When starting the rqworker and rqinfo scripts with an --url parameter containing a non default database, e.g. redis://localhost:6379/2, both scripts connected db 0 instead of the desired database. Fixed this behavior by ignoring the --host, --port and --db arguments if --url is there.

Also fixed another issue with the rqinfo script, in which it defaulted to only the 'default' queue instead of finding all available queues using Queue.all().
 12 years ago
Selwin Ong a0c9267550 Job.create should also accept arguments in list format. 13 years ago
Vincent Driessen 067a1760ed Merge branch 'Plexical-config-socket' 13 years ago
Bruno Renié 7a8fe6be30 Ability to get SENTRY_DSN from the environment variables 13 years ago
Jacob Oscarson 11b2cf2bd5 Perform actual connection (+ increase test coverage) 13 years ago
Jacob Oscarson ef43790ba2 Better placing + testability of socket as a cli parameter 13 years ago
Jacob Oscarson 02288dd048 Optionally configure connection as path to Unix socket (tbd: actual connection) 13 years ago
Vincent Driessen 5a5e14cc70 Merge branch 'hotfix/0.3.7' 
Conflicts:
	CHANGES.md
	rq/version.py
 13 years ago
Vincent Driessen 93ba0b4d6e Bump version to 0.3.7. 13 years ago
Vincent Driessen 66741fff7b Fix bug where workers would not execute builtin functions properly. 13 years ago
Vincent Driessen 9633d36e85 Merge branch 'selwin-master' 13 years ago
Vincent Driessen 5289647970 Remove unused import. 13 years ago
Selwin Ong 85e9014296 Moved some logic from worker.perform_job() to job.cleanup(). 13 years ago
Vincent Driessen 6485fe094d Prepare for next 0.3.x version. 13 years ago
Vincent Driessen d5f1740c3d Bump version to 0.3.6. 13 years ago
Vincent Driessen a04169e561 Allow rqworker to run more silently. 13 years ago
Selwin Ong c987569650 Safe fetching a deleted job removes the deleted job from queue. 13 years ago
Vincent Driessen 501a3870e1 Ignore a job when there isn't a "data" key available. 13 years ago
Vincent Driessen 223e09f4fe Add rq.contrib.legacy.cleanup_ghosts() function, to clean up old mess. 13 years ago
Vincent Driessen d39badb4cc Prevent the use of indefinite timeouts. 
Using them would really mess with the new expiring worker keys (they
would disappear, even though the workers aren't dead).
 13 years ago
Vincent Driessen e0866cdc6c Log the act of sending a heartbeat (DEBUG level). 13 years ago
Vincent Driessen e4d37332f0 Fix typos. 13 years ago
Vincent Driessen e8c1885eda Avoid negative timeouts when default_worker_ttl is < 60. 13 years ago
Vincent Driessen 640195d5e4 Merge branch 'master' into yaniv-aknin-worker_ttl 13 years ago
Vincent Driessen a7f927f845 Fix non-relative import. 13 years ago
Vincent Driessen 192770773a Remove unused import. 13 years ago
Vincent Driessen c0a594d47a Merge pull request #177 from selwin/master 
FailedQueue.requeue should set job status back to Queued
 13 years ago
Selwin Ong e5fa82aa5d Merge branch 'master' of github.com:selwin/rq 13 years ago
Selwin Ong 05d744c9af Requeuing a job should set its status back to Queued. 13 years ago
Vincent Driessen 4688498e2d Attach job ID when unpickling fails in .dequeue(). 
This makes the behaviour consistent with .dequeue_any().
 13 years ago
Vincent Driessen 83525c42c7 Prevent against 'created_at' field being None. 13 years ago
Vincent Driessen 7d37c257ae Prepare for 0.3.6. 13 years ago
Vincent Driessen c427eda36c Bump version to 0.3.5. 13 years ago
Vincent Driessen 54254f2271 Patch the connection instances. 
This patches the connection object (which is either a StrictRedis
instance or a Redis instance), to have alternative class methods that
behave exactly like their StrictRedis counterparts, no matter whether
which type the object is.  Only the ambiguous methods are patched.  The
exhaustive list:

- _zadd          (fixes argument order)
- _lrem          (fixes argument order)
- _setex         (fixes argument order)
- _pipeline      (always returns a StrictPipeline)
- _ttl           (fixes return value)
- _pttl          (fixes return value)

This makes it possible to call the methods reliably without polluting
the RQ code any further.
 13 years ago
Vincent Driessen 67880343f1 Make inner_exception optional, and use new except syntax. 13 years ago
Idan Kamara 2baa2e370f job: save the real exception when unpickling fails 
We raise our own exception which hides the real error (often an ImportError),
making it difficult to see what happend. Instead, save the original exception
too.
 13 years ago
Yaniv Aknin 4925b09aa5 Set worker ttl and maintain it when idle/taking/finishing jobs 
This change could use far better test coverage, but I'm not sure how to
test it without refactoring more of the code than I think is reasonable
in the scope of this work.
 13 years ago
Yaniv Aknin 74c2351232 Refactor dequeue_any to accept arbitrary timeouts 
The 'blocking' parameter was replaced with a 'timeout' parameter.

The timeout parameter is interpreted thus:
    0 - no timeout (block forever, equivalent to blocking=True)
    None - non-blocking (return value or None immediately, equivalent to
                         blocking=False)
    <integer> - maximum seconds to block

Upon timing out, a dequeue operation will raise DequeueTimeout.
 13 years ago
Vincent Driessen 743cf3cd74 Merge branch 'vierja-ended_time' 13 years ago
Vincent Driessen 20d435a077 Prepare for 0.3.5. 13 years ago
Vincent Driessen f818fb5d43 Bump version to 0.3.4. 13 years ago
Vincent Driessen e1b81b1669 Avoid new-style classes under Python 2.6. 
Little ugly fix, required because Python 2.6's logging uses old-style
classes.  Thanks for finding this one, @deferraz.
 13 years ago
Vincent Driessen 77fb32791d Include a copy of dictConfig in RQ, for Python 2.6 compat. 13 years ago