Vincent Driessen
|
45ac484c5c
|
Merge pull request #421 from selwin/finished-registry
Added FinishedJobRegistry to monitor/view completed jobs
|
10 years ago |
Selwin Ong
|
2307bc8253
|
Added FinishedJobRegistry to monitor finished jobs.
|
10 years ago |
Selwin Ong
|
74a9982ecb
|
Fixed a bug where expired jobs aren't deleted from JobStartedRegistry.
|
10 years ago |
Selwin Ong
|
18c6ea64ef
|
Merge pull request #419 from selwin/registry-len
Added JobStartedRegistry.count
|
10 years ago |
zhangliyong
|
f9511664c8
|
Make flake8 happy :)
|
10 years ago |
zhangliyong
|
1b39996bf7
|
Make pep8
|
10 years ago |
zhangliyong
|
94e494e645
|
Add testcase for rq worker command
|
10 years ago |
zhangliyong
|
c6033b312e
|
Cleanup
|
10 years ago |
zhangliyong
|
918403e371
|
Update test_cli
|
10 years ago |
zhangliyong
|
6510bb46f3
|
Fix interval type bug, it should be float
|
10 years ago |
zhangliyong
|
21c14c0e21
|
Cleanup
|
10 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.
|
10 years ago |
zhangliyong
|
4df076f3aa
|
Retrieve url from config file
|
10 years ago |
zhangliyong
|
229a00fee5
|
Cleanup
|
10 years ago |
zhangliyong
|
88fe5124d8
|
Make pythonic
|
10 years ago |
zhangliyong
|
907e71dc86
|
Make pythonic
|
10 years ago |
zhangliyong
|
f10c749b7c
|
Use click's evvar to retrieve SENTRY_DSN environment value
|
10 years ago |
zhangliyong
|
842f27294a
|
Convert rqworker to 'rq worker' subcommand
|
10 years ago |
zhangliyong
|
7b434a32eb
|
Let cleanup_ghosts accept conn argument
|
10 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
|
10 years ago |
Selwin Ong
|
c1dc30eae3
|
Added __len__ method to Queue.
|
10 years ago |
Selwin Ong
|
fae7df5aa7
|
Renamed StartedJobRegistry.get_job_count to StartedJobRegistry.count for consistency.
|
10 years ago |
Selwin Ong
|
41ae1ce8a7
|
Added a registry.get_job_count().
|
10 years ago |
Cal Leeming
|
6aa2e18f88
|
Another unused import, oops
|
10 years ago |
foxx
|
30ea76ddd6
|
Fixed silly typo
|
10 years ago |
foxx
|
0466562a13
|
Fixes from comments in #415
Added tox/vagrant tmp dir to gitignore
Removed unused import
Renamed id to job_id in enqueue_call() as per comments in #415
|
10 years ago |
Vincent Driessen
|
783b6f9ec7
|
Fix PEP8 complaint.
|
10 years ago |
Vincent Driessen
|
7686785d61
|
Merge branch 'selwin-working-queue'
Conflicts:
tests/test_worker.py
|
10 years ago |
Vincent Driessen
|
4b7c59d68d
|
Fix PEP8 complaints.
|
10 years ago |
Vincent Driessen
|
aa3cf85531
|
Run flake8 checks as part of test suite.
|
10 years ago |
Selwin Ong
|
6d79082b62
|
Call move_expired_jobs_to_failed_queue before returning job_ids.
|
10 years ago |
Selwin Ong
|
dc12f8aee5
|
Fixed random registry failures when run on slower machines.
|
10 years ago |
Selwin Ong
|
5a27ad540f
|
Merge branch 'working-queue' of https://github.com/selwin/rq into working-queue
Conflicts:
tests/test_worker.py
|
10 years ago |
Selwin Ong
|
9341a4a33d
|
Renamed WorkingQueue to StartedJobRegistry.
|
10 years ago |
Selwin Ong
|
2e96148b31
|
Fixed Python 3 tests for "WorkingQueue".
|
10 years ago |
Selwin Ong
|
60c7a3cc6e
|
working_queue.remove call should be pipelined.
|
10 years ago |
Selwin Ong
|
4d90cc062e
|
Add job to WorkingQueue before execution and remove from WorkingQueue after.
|
10 years ago |
Selwin Ong
|
b0c0a84ab0
|
Moved some logic into worker.prepare_job_execution to make things testable.
|
10 years ago |
Selwin Ong
|
a28575088b
|
Implemented WorkingQueue.cleanup().
|
10 years ago |
Selwin Ong
|
3dc008d090
|
Added WorkingQueue class.
|
10 years ago |
Selwin Ong
|
1047db0b3a
|
Renamed WorkingQueue to StartedJobRegistry.
|
10 years ago |
Selwin Ong
|
1158a0606c
|
Fixed Python 3 tests for "WorkingQueue".
|
10 years ago |
foxx
|
b6499ce71c
|
Fixed another py3 bug - my bad. Also moved type checking further down
|
10 years ago |
Vincent Driessen
|
85badaf4a0
|
Indicate required Redis version in README.
|
10 years ago |
foxx
|
f5779c194f
|
Renamed job_id to id, and fixed py3 bug, per #415
|
10 years ago |
Vincent Driessen
|
9ab46804c6
|
Merge pull request #417 from foxx/feature/testworker
Added test worker for unit tests - fixes #413
|
10 years ago |
foxx
|
52c3ad0fbf
|
Renamed to SimpleWorker
|
10 years ago |
foxx
|
23cae3a420
|
Fixed bug caused by broken merge, my bad
|
10 years ago |
foxx
|
16ee71f26d
|
Use class for test worker, and performs PID check in unit tests, #412
|
10 years ago |
Selwin Ong
|
d667fb0713
|
working_queue.remove call should be pipelined.
|
10 years ago |