- Allow to decorate corofunctions by
celery.signals
- Implement pool capacity (
-c, --concurency
)
- Finalize monkey patcher refactoring. Now you able to switch off applying of any monkey patch. Remember with great power comes great responsibility
- Implement
soft_time_limit
- Implement
revoke
- Fix keywords
- Total monkey patching refactor. Now it is enabled by default, but you can
manually disable some of features using environment variable
CPA_MONKEY_DENY
- Make Celery Beat working
- Add async Celery Scheduler
- More monkey patching
- Move loop and loop_runner to own module
- Avoid creating multiple loops and loop_runners per application
- Large rework of
await AsyncResult.get()
- Works much better than earlier, but it's crap still
- Added outnumber of monkey-patches
- Fixed race condition on first microseconds of pool shutdown
- Cleanup tracer, use celery.app.trace namespase where it possible
- Refactor monkey, split it
- Move
patch_send_task
to own function - Add
patch_result_get
toawait AsyncResult.get
- Avoid building trace twice
- Also this small performance optimization fixed
AsyncResult.get
- Fix graceful shutdown
- Fix monkey: another function must be patched
- Add changelog
- Append documentation
- Add monkey patcher to make brocker IO operations nonblocking
- Refactor code
- Fix found errors
- Initial commit