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.
9 years ago
Selwin Ong
a14041ae1a
Merge pull request #640 from gisce/when_not_async_set_job_finished
...
When not async set job finished
9 years ago
Eduard Carreras
89facfada6
Test to ensure job is finished in not async mode
9 years ago
Eduard Carreras
c27a6434a8
Set job as finished when not working in async mode
9 years ago
Selwin Ong
84b711b5a5
Merge pull request #639 from nicksnell/fix/worker-results-ttl
...
Correction to results-ttl value on worker command
9 years ago
Nick Snell
0e532f3ec4
Correction to worker command, cast results-ttl to int
9 years ago
Christophe Olinger
b47c8efe27
Add test cases for shutdown_requested_date
9 years ago
Christophe Olinger
2be468a404
- Rename paramter both in redis and python to shutdown_requested_date
...
- Use connection instead of pipeline
9 years ago
Christophe Olinger
ae27ce9871
Merge branch 'master' into warmshutdown
9 years ago
Selwin Ong
00645434ac
Merge pull request #637 from olingerc/remove_current_job
...
worker left with current_job set after job exception
9 years ago
Christophe Olinger
3e586bd6d6
Add remove current_job based on the correct upstream master branch
9 years ago
Christophe Olinger
d622f47aff
Save date in redis on which worker receives a warm shutdown request while busy
9 years ago
Selwin Ong
2485334100
Merge pull request #609 from tornstrom/master
...
Allow meta when enqueing
9 years ago
Vincent Driessen
6fe277bb6c
Merge pull request #628 from SkyLothar/master
...
make sure state and exc_info is text_type
9 years ago
SkyLothar
70b5554566
make sure exc_info is text type
9 years ago
SkyLothar
f9978bc27c
make sure state text_type
9 years ago
Tornstrom
50a114a0a8
Allow meta when enqueing
9 years ago
Selwin Ong
45addbcaf2
Deleted job.set_started_at_now.
9 years ago
Selwin Ong
364919c7c8
Moved job.hset_value to connection._hset.
9 years ago
Selwin Ong
10f615f4fe
Reverted click requirement back to >= 3.0
9 years ago
Selwin Ong
961e443611
Merge pull request #619 from foxx/patch-1
...
Fixes #613
9 years ago
Selwin Ong
5afd1a90e5
Merge pull request #589 from samuelcolvin/job-started_at
...
add job.started_at
9 years ago
Samuel Colvin
6fc34dc6a6
moving started_at to prepare_job_execution
9 years ago
Cal Leeming
e76bde9bc0
Fix broken tests
9 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.
9 years ago
Selwin Ong
8bbd833855
Merge pull request #600 from glaslos/cancel_remove
...
Cancel and Delete differences
9 years ago
Selwin Ong
702dfd2c31
Merge pull request #611 from ahxxm/delay-task
...
depreciation fixes
9 years ago
Selwin Ong
73d0dda516
Merge pull request #581 from mgk/master
...
export worker id and job id as env vars to work horse
9 years ago
Michael Keirnan
14723ecc1f
Merge remote-tracking branch 'upstream/master'
9 years ago
ahxxm
95e06818d9
ignore IDE cache folder
9 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
9 years ago
Selwin Ong
91177b7317
Merge pull request #601 from glaslos/registry_cleanup_log_msg
...
log.info added when cleaning registries
9 years ago
Selwin Ong
9f9a5650aa
Merge pull request #599 from kfrendrich/master
...
rqinfo config parameter
9 years ago
glaslos
a424d320a8
log.info added when cleaning registries
9 years ago
Karoly Frendrich
ca069e5112
rqinfo config parameter
9 years ago
glaslos
0a6df13d9d
delete dependents and delete in cleanup. Fixed tests.
9 years ago
glaslos
d2eeb3b3db
job.cancel before delete and doc string fixes
9 years ago
glaslos
02844034d7
Merge branch 'master' into cancel_remove
9 years ago
glaslos
5a3bebf85b
only remove from queue on job.cancel
9 years ago
Selwin Ong
bd7b642251
Merge pull request #594 from horida/master
...
mark as busy before forking horse
9 years ago
horida
04987a80da
mark as busy before forking horse
9 years ago
Samuel Colvin
3aa7aebf87
remove assert_dt_between from worker tests
9 years ago
Selwin Ong
95f740299a
Merge pull request #588 from samuelcolvin/logging-extras
...
more info in 'Job OK' log entry
9 years ago
Selwin Ong
aac554e349
Merge pull request #587 from samuelcolvin/signal-changes
...
Signal changes
9 years ago
Samuel Colvin
1349e90ba2
test docstrings, and sentinel test
9 years ago
Samuel Colvin
082e61a212
add job.started_at
9 years ago
Samuel Colvin
30c29614c6
more info in 'Job OK' log entry
9 years ago
Samuel Colvin
fa48751fed
correct SLOW env var, run slow tests on ci
9 years ago
Samuel Colvin
aada162a4d
worker shutdown tests
9 years ago