Vincent Driessen
39258e2c15
Release 0.4.0.
11 years ago
Vincent Driessen
aef7af9c77
Merge pull request #334 from nvie/emptying-failed-queue
...
Emptying failed queue
11 years ago
Vincent Driessen
7ea106e50e
Merge pull request #333 from selwin/explicit-args
...
Rearranged how explicit kwargs are passed into queue.enqueue(). Fixes #322
11 years ago
Vincent Driessen
cb34acc279
Add rqinfo -X command.
...
This can be used to empty the failed queue right from the command line.
11 years ago
Vincent Driessen
4d9c20d5d9
Reimplement Queue.empty() in a Lua script.
...
This makes the .empty() function perform all the computing in Redis
itself, rather than in Python. This is both atomic, and faster.
11 years ago
Vincent Driessen
057c4657ef
Fix whitespace.
11 years ago
Vincent Driessen
fdf4abcf69
Fix pipeline call.
11 years ago
Selwin Ong
4f918041e3
Rearranged how explicit kwargs are passed into queue.enqueue(). Fixes #322
11 years ago
Vincent Driessen
76e2470c67
Merge pull request #332 from tomashanacek/master
...
rqworker default arguments of socket, worker_ttl, results_ttl bugfix
11 years ago
Tomas Hanacek
6494233058
rqworker default arguments of socket, worker_ttl, results_ttl bugfix
11 years ago
Vincent Driessen
35d839f4e2
Merge pull request #330 from selwin/death-penalty
...
Job timeouts are now handled by "worker.death_penalty_class"
11 years ago
Vincent Driessen
3649ff863b
Don't rely on external package `first`.
11 years ago
Selwin Ong
7eb6c2ab9f
Job timeouts are now handled by "worker.death_penalty_class".
11 years ago
Vincent Driessen
a55be12864
Merge branch 'malthe-default-to-environment-args'
11 years ago
Vincent Driessen
3667e37ed3
Don't expose the envvar values through `rqinfo -h`.
11 years ago
Vincent Driessen
1ada3462dd
Merge pull request #329 from olingerc/workonrqinfo
...
Use get_state() instead of .state in rqinfo
11 years ago
Christophe Olinger
e16b89de3b
Use get_state() instead of .state in rqinfo
11 years ago
Selwin Ong
56053a33ec
Merge pull request #321 from selwin/cleanup-worker.work
...
Simplify worker.work() by moving some functionalities to relevant methods
11 years ago
Malthe Borch
e77b3e8a21
Pull argument parser defaults from environment variables.
11 years ago
Vincent Driessen
dbcba85815
Properly declare Python 3 compatibility.
11 years ago
Selwin Ong
835c353380
Job status should be updated during job.perform().
11 years ago
Selwin Ong
57990fa052
Simplify worker.work() by moving some functionalities to relevant methods.
11 years ago
Vincent Driessen
f39949eede
Merge pull request #320 from selwin/deprecate-job-status
...
Deprecate job.status
11 years ago
Selwin Ong
f5c3c9a6dd
Deprecate job.status.
11 years ago
Vincent Driessen
97f8ac8c76
Merge pull request #319 from selwin/worker-get_job_id
...
Worker.get_current_job()
11 years ago
Selwin Ong
72457d2286
Added DeprecationWarning to worker.state.
11 years ago
Selwin Ong
2fe5d9e25e
Python 3 compatibility with worker.get_current_job().
11 years ago
Selwin Ong
802ecb5ccb
Renamed worker.set_job_id() and worker.get_job_id() for consistency.
11 years ago
Selwin Ong
93bb9ec5f4
Added tests for worker.get_current_job().
11 years ago
Selwin Ong
1b3832adb5
Merge branch 'master' of https://github.com/mbr/rq into worker-get_job_id
...
Conflicts:
rq/worker.py
11 years ago
Selwin Ong
37376cfe42
Deprecate worker.state.
11 years ago
Vincent Driessen
383ffa464f
Merge branch 'rdooley-master'
11 years ago
Vincent Driessen
d2bbd31c59
Fix some flake8 complaints.
11 years ago
Vincent Driessen
f7e2375b36
Remove two-char short args.
...
In UNIX, this would mean the shorthand notation for `-w -t`, which is
confusing and conflicts with the existing `-w` and `-t` flags. Instead,
if you need this, you'll have to spell the flag name out because we've
run out of chars that make sense.
11 years ago
Vincent Driessen
c7498b2066
Merge pull request #312 from selwin/rename-fork_and_perform
...
Renamed Worker.fork_and_perform_job to Worker.execute_job.
11 years ago
Vincent Driessen
776ed0a1d5
Merge pull request #314 from malthe/add-job-repr
...
Add repr for `Job` (showing id and enqueue time)
11 years ago
Malthe Borch
ad529e2609
Add repr for (showing id and enqueue time).
11 years ago
Selwin Ong
2044e790f5
Renamed Worker.fork_and_perform_job to Worker.execute_job.
11 years ago
Rees Dooley
fb65e321ed
Changed timeout to results_ttl. Added similar worker_ttl param
11 years ago
Rees Dooley
f8e775a784
Results timeout arg added to rqworker
11 years ago
Marc Brinkmann
e81ee5b672
Update worker.py
...
Use docstring instead of comment. Sorry.
11 years ago
Vincent Driessen
9ad7da684c
Merge branch 'KanbanSolutions-use-pipeline-context'
11 years ago
Vincent Driessen
d0381e98ee
Fix .pipeline -> ._pipeline.
...
This makes sure it's compatible with both Redis and StrictRedis back
ends.
11 years ago
Selwin Ong
19da7616b0
Merge pull request #302 from sylvinus/patch-1
...
Added connection argument to get_current_job()
11 years ago
Sylvain Zimmer
f0a3dd262e
Added connection argument to get_current_job()
11 years ago
Vincent Driessen
c106604f17
Add note that custom worker classes are now supported.
11 years ago
Dj Gilcrease
fd036538f7
Wrap the perform_job try/except in a pipeline context so the pipeline connection is properly refrshed after the work is done
11 years ago
Vincent Driessen
a2213f1364
Fix tests.
11 years ago
Vincent Driessen
85a7a14a4c
Replace substring in Pickle string differently.
...
Pickle uses a new format since Python 3, which is incompatible with
Python 2. This problem now pops up because the replacement string had
a different length, so we broke the pickle protocol with this test.
11 years ago
Vincent Driessen
d08352b103
Update CHANGES.
11 years ago