| Commit message (Collapse) | Author | Age | Files | Lines |
| | |
|
| | |
|
| |
|
|
| |
fix https://github.com/celery/celery/issues/5299
|
| | |
|
| | |
|
| |
|
|
|
|
| |
* reset ready before execute callback
* add test to cover hub._ready reset to empty
|
| |
|
|
|
|
| |
* don't stop receiving tasks on 503 SQS error.
* fix linter errors
|
| |
|
|
|
|
| |
* return empty list on SQS internal error.
* add test for on_list_ready error codes
|
| | |
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* On restore changes message visibility instead of send new message
* Acknowledge message on hub close
* Use sqs instead of async sqs to delete message
* changes itertools to range
* Empty Hub ready
* fixed test_poller_regeneration_on_access
* Fixed typo in comment
* Simplify loop to process self._ready
* Added test case for redelivered _put
* Lint fixes
* Added test case for delete_message call
|
| | |
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
multiple times (#866)
* Regenerate poll()s of Hub and Redis, after shutdown
Allows the same Python process to bring a new Worker
after a shutdown (SystemExit) rescued.
See: https://botbot.me/freenode/celery/2018-04-16/?msg=99046233&page=2
* Hub.poller is now a @property
* Fixed tests that supose .poller to be settable to None
* Test hub.pooler regeneration
* No need to regenerate poller on Redis if the Hub behaves nicely
|
|
|
* Rename `async` keyword to `asynchronous`
* Fixes #742
* Resolves "DeprecationWarning: 'async' and 'await' will become reserved
keywords in Python 3.7"
* Address PR feedback
* Update appveyor config
* Rename docs and tests
|