🦀 Rust implementation of Celery for producing and consuming background tasks
0bb5873 skip warning about redis heartbeat when not necessary (#365) 74c7cfe Fix the minimal versions problem (#358) 1b50565 Bump chrono version for with_ymd_and_hms (#357) 32cb1c9 Bump actions/checkout from 1 to 3 (#353)
76c86cd build(ci-deps): Update github actions (#348) d07f58f build(deps): Upgrade all deps (#347)
72bfbda Fix intradoc links to macros d67df84 fix some lint complaints 0bca055 [chore] (cargo-release) v0.4.0 a966d04 Add Rustls support (#292) 1bf8729 Bumps Tokio dependencies to latest version (#324)
0ab57af derive Serialize, Deserialize for TaskError (#274) 18ae003 Update serde-pickle requirement from 0.6 to 1.1 (#272) 341de2f style: correct typos (#273) d1d68fb (scripts/brokers): bind brokers to localhost only (#270) ab24e06 Bump mypy from 0.812 to 0.910 (#249) 4d9e035 Bump black from 21.5b0 to 21.9b0 (#268)
app!
and beat!
related to issue #250.2b395cf fix
⚠️ BREAKING CHANGE ⚠️
The RegularSchedule
in the beat
module has been renamed to DeltaSchedule
to
be more coherent with Python Celery terminology, where it is sometimes called timedelta.
Tokio updated to 1.0.0.
The Broker::configure_task_routes
produces BrokerError
instead of CeleryError
.
The beat
macro now expects a list of tasks that is used to initialize the scheduler.
Errors have been refactored:
BadRoutingPattern
variant has been moved from CeleryError
to BrokerError
;CronScheduleError
has been replaced by a ScheduleError
enum with a CronScheduleError
variant;ScheduleError
variant has been added to BeatError
BadRoutingPattern
error has been added.max_sleep_duration
property on the Beat
which can be used to ensure that
the scheduler backend is called regularly (which may be necessary for custom backends).Beat::schedule_named_task
to add a scheduled task with a custom name.Broker::cancel
to cancel an existing consumer.Ok
variant type of the the return type of Broker::consume
. This is now a tuple that includes a unique
consumer tag that can then be passed to Broker::cancel
to cancel the corresponding consumer.AMQPBroker::close()
that would result in an error with lapin
.celery::app!
macro that caused it to fail to compile when the broker connection string was passed as a variable instead of an expression.7ab2443 (cargo-release) v0.4.0-rc7 5f28972 fix release job 10a269b Merge pull request #261 from rusty-celery/ci-matrix-builds 63a0a2c final touches b0f6117 remove build step (redundant) 66f4ecb more updates 41cb7c4 updates 790e5d9 add prerelease indicator 876a138 release process 8c2c2a7 Fix 5d24730 fixes, remove Windows builds 3369d59 fix again a2197e4 try fix 63ae066 use matrix build strategy 335ec05 Merge pull request #260 from rusty-celery/ci-updates 3b7fa55 fix lint errors b6cdfce fix AMQP broker integration test a6f0bde Merge pull request #251 from rusty-celery/app-macro-fix c33e6de fix bug with celery::app! macro bf300c2 Merge pull request #239 from ajesipow/message-builder-fields cf45c41 update changelog 60b5156 Merge branch 'main' into message-builder-fields d06cd0f Merge pull request #238 from rusty-celery/dependabot/pip/black-21.5b0 fe93568 Merge branch 'main' into dependabot/pip/black-21.5b0 47faaad Merge pull request #240 from rusty-celery/disable-coverage-for-now 7c4220f Update ci.yml 9ccbc07 set additional message fields f0b3560 Bump black from 21.4b2 to 21.5b0 1a8eb75 Merge pull request #237 from rusty-celery/dependabot/pip/black-21.4b2 a605c24 Bump black from 21.4b1 to 21.4b2 e273654 Merge pull request #236 from rusty-celery/dependabot/pip/black-21.4b1 c86820d Bump black from 21.4b0 to 21.4b1 cc6f3c2 Merge pull request #235 from rusty-celery/dependabot/pip/black-21.4b0 7ccb45d fix lints 02dd941 Bump black from 20.8b1 to 21.4b0 37198a0 Merge pull request #232 from rusty-celery/dependabot/cargo/redis-0.20.0 326f816 Merge branch 'main' into dependabot/cargo/redis-0.20.0 46f4292 Bump mypy from 0.800 to 0.812 (#233) 306eff8 Merge branch 'main' into dependabot/pip/mypy-0.812 616b019 fix test e9a8e81 Merge branch 'main' into dependabot/pip/mypy-0.812 49e1c34 fixes for new clippy 9e3033c Bump mypy from 0.800 to 0.812 79c9d5f Update redis requirement from 0.19.0 to 0.20.0 5928c2d Bump mypy from 0.790 to 0.800 (#230) 7deb727 Modify the beat macro to accept a list of tasks to schedule (#222) 365ad08 Change redis delivery msg to comply with python message (#228) 4c54574 Add coverage badge (#227) 1fb62af Add code coverage check to CI (#224) 7d76af1 Merge pull request #226 from rusty-celery/ci-fixes 821309e fix new lints bb8918d refresh cache daily instead of weekly a60e837 increase timeout in AMQP broker test f73ae03 Tokio 1.0.0 redis update (#223) 133ec2d Rename RegularSchedule to DeltaSchedule in the beat module (#211) be02c6f rename 'master' branch to 'main' e0c2585 fix bug closing AMQP connection (#214) d2e6e4e Update rand requirement from 0.7 to 0.8 (#212) 2aa370d revert rc6 release until new redis-rs release adc798c ensure release job depends on redis checks 73614bf (cargo-release) v0.4.0-rc6 fe0d683 Add check for Redis broker in README f9755d0 Add support for Redis as a broker (#181) cd84739 Update rmp-serde requirement from 0.14 to 0.15 (#207) fca2ea5 AMQP fixes (#206) ddebcb3 temporarily comment out broken amqp test b0e4eaa Add the max_sleep_duration property to the Beat (#204)