[bump] introduce new version: 0.6

.github/workflows/cd.yaml

@@ -31,10 +31,7 @@ jobs:
           # vX.Y.Z-foo is pre-release version
           VERSION=${GITHUB_REF#refs/tags/v}
           VERSION_NUMBER=${VERSION%-*}
-          PUBLISH_OPTS="--dry-run"
-          if [[ $VERSION == $VERSION_NUMBER ]]; then
-            PUBLISH_OPTS=""
-          fi
+          PUBLISH_OPTS=""
           echo VERSION=${VERSION} >> $GITHUB_ENV
           echo PUBLISH_OPTS=${PUBLISH_OPTS} >> $GITHUB_ENV
           echo VERSION_NUMBER=${VERSION_NUMBER} >> $GITHUB_ENV

.github/workflows/ci.yaml

@@ -20,7 +20,7 @@ jobs:
       - uses: actions-rs/cargo@v1
         with:
           command: check
-          args: --features tokio-comp
+          args: --all
       - uses: actions-rs/cargo@v1
         with:
           command: check
@@ -39,7 +39,7 @@ jobs:
       - uses: actions-rs/cargo@v1
         with:
           command: test
-          args: --features tokio-comp
+          # args: --all
 
 
   fmt:

.github/workflows/mysql.yaml

@@ -1,11 +1,4 @@
 on:
-  push:
-    paths:
-      - "packages/apalis-sql/src/lib.rs"
-      - "packages/apalis-sql/mysql.rs"
-      - "packages/apalis-sql/src/migrations/mysql/**"
-      - "packages/apalis-sql/src/Cargo.toml"
-      - ".github/workflows/mysql.yaml"
   pull_request:
     paths:
       - "packages/apalis-sql/src/lib.rs"

.github/workflows/postgres.yaml

@@ -1,11 +1,4 @@
 on:
-  push:
-    paths:
-      - "packages/apalis-sql/src/lib.rs"
-      - "packages/apalis-sql/postgres.rs"
-      - "packages/apalis-sql/src/migrations/postgres/**"
-      - "packages/apalis-sql/src/Cargo.toml"
-      - ".github/workflows/postgres.yaml"
   pull_request:
     paths:
       - "packages/apalis-sql/src/lib.rs"
@@ -37,4 +30,4 @@ jobs:
           toolchain: stable
           override: true
       - run: cargo test --no-default-features --features postgres,migrate,tokio-comp -- --test-threads=1
-        working-directory: packages/apalis-sql
+        working-directory: packages/apalis-sql

.github/workflows/redis.yaml

@@ -1,8 +1,4 @@
 on:
-  push:
-    paths:
-      - "packages/apalis-redis/**"
-      - ".github/workflows/redis.yaml"
   pull_request:
     paths:
       - "packages/apalis-redis/**"
@@ -26,11 +22,11 @@ jobs:
           profile: minimal
           toolchain: stable
           override: true
-      - run: cargo test --features tokio-comp -- --test-threads=1
+      - run: cargo test -- --test-threads=1
         working-directory: packages/apalis-redis
         env:
           REDIS_URL: redis://127.0.0.1/
-      - run: cargo test --features async-std-comp -- --test-threads=1
+      - run: cargo test -- --test-threads=1
         working-directory: packages/apalis-redis
         env:
           REDIS_URL: redis://127.0.0.1/

.github/workflows/sqlite.yaml

@@ -1,11 +1,4 @@
 on:
-  push:
-    paths:
-      - "packages/apalis-sql/src/lib.rs"
-      - "packages/apalis-sql/src/sqlite.rs"
-      - "packages/apalis-sql/src/migrations/sqlite/**"
-      - "packages/apalis-sql/src/Cargo.toml"
-      - ".github/workflows/sqlite.yaml"
   pull_request:
     paths:
       - "packages/apalis-sql/src/lib.rs"
@@ -28,4 +21,4 @@ jobs:
           toolchain: stable
           override: true
       - run: cargo test --no-default-features --features sqlite,migrate,tokio-comp -- --test-threads=1
-        working-directory: packages/apalis-sql
+        working-directory: packages/apalis-sql

Cargo.toml

@@ -4,7 +4,7 @@ repository = "https://github.com/geofmureithi/apalis"
 
 [package]
 name = "apalis"
-version = "0.5.5"
+version = "0.6.0"
 authors = ["Geoffrey Mureithi <mureithinjuguna@gmail.com>"]
 description = "Simple, extensible multithreaded background job processing for Rust"
 edition.workspace = true
@@ -19,18 +19,8 @@ categories = ["database"]
 bench = false
 
 [features]
-default = ["tracing", "tokio-comp"]
-
-## Include redis storage
-redis = ["apalis-redis"]
-## Include Postgres storage
-postgres = ["apalis-sql/postgres"]
-## Include SQlite storage
-sqlite = ["apalis-sql/sqlite"]
-## Include MySql storage
-mysql = ["apalis-sql/mysql"]
-## Include Cron functionality
-cron = ["apalis-cron"]
+default = ["tracing"]
+
 
 ## Support Tracing 👀
 tracing = ["dep:tracing", "dep:tracing-futures"]
@@ -47,20 +37,8 @@ timeout = ["tower/timeout"]
 limit = ["tower/limit"]
 ## Support filtering jobs based on a predicate
 filter = ["tower/filter"]
-## Compatibility with async-std and smol runtimes
-async-std-comp = [
-  "apalis-sql?/async-std-comp",
-  "apalis-redis?/async-std-comp",
-  "apalis-cron?/async-std-comp",
-  "async-std",
-]
-## Compatibility with tokio and actix runtimes
-tokio-comp = [
-  "apalis-sql?/tokio-comp",
-  "apalis-redis?/tokio-comp",
-  "apalis-cron?/tokio-comp",
-  "tokio",
-]
+## Captures panics in executions and convert them to errors
+catch-panic = []
 
 layers = [
   "sentry",
@@ -70,35 +48,16 @@ layers = [
   "timeout",
   "limit",
   "filter",
+  "catch-panic",
 ]
 
 docsrs = ["document-features"]
 
-[dependencies.apalis-redis]
-version = "0.5.5"
-optional = true
-path = "./packages/apalis-redis"
-default-features = false
-
-[dependencies.apalis-sql]
-
-version = "0.5.5"
-features = ["migrate"]
-optional = true
-default-features = false
-path = "./packages/apalis-sql"
-
 [dependencies.apalis-core]
-version = "0.5.5"
+version = "0.6.0"
 default-features = false
 path = "./packages/apalis-core"
 
-[dependencies.apalis-cron]
-version = "0.5.5"
-optional = true
-default-features = false
-path = "./packages/apalis-cron"
-
 [dependencies.document-features]
 version = "0.2"
 optional = true
@@ -116,22 +75,24 @@ pprof = { version = "0.14", features = ["flamegraph"] }
 paste = "1.0.14"
 serde = "1"
 tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
-apalis = { path = ".", features = ["redis", "sqlite", "postgres", "mysql"] }
-redis = { version = "0.25.3", default-features = false, features = [
-    "script",
-    "aio",
-    "connection-manager",
+apalis = { path = ".", features = ["limit"] }
+apalis-redis = { path = "./packages/apalis-redis" }
+apalis-sql = { path = "./packages/apalis-sql", features = [
+  "postgres",
+  "mysql",
+  "sqlite",
+] }
+redis = { version = "0.27", default-features = false, features = [
+  "tokio-comp",
+  "script",
+  "aio",
+  "connection-manager",
 ] }
 
 [dev-dependencies.sqlx]
 version = "0.8.1"
 default-features = false
-features = ["chrono", "mysql", "sqlite", "postgres"]
-
-
-[[bench]]
-name = "storages"
-harness = false
+features = ["chrono", "mysql", "sqlite", "postgres", "runtime-tokio"]
 
 [workspace]
 members = [
@@ -150,17 +111,22 @@ members = [
   "examples/axum",
   "examples/prometheus",
   "examples/tracing",
-  # "examples/rest-api",
   "examples/async-std-runtime",
   "examples/basics",
+  "examples/redis-with-msg-pack",
+  "examples/redis-deadpool",
+  "examples/redis-mq-example",
+  "examples/cron",
+  "examples/catch-panic",
+  "examples/graceful-shutdown",
+  "examples/unmonitored-worker",
+  "examples/fn-args",
+  "examples/persisted-cron",
+  "examples/rest-api",
 ]
 
 
 [dependencies]
-tokio = { version = "1", features = [
-  "rt",
-], default-features = false, optional = true }
-async-std = { version = "1", optional = true }
 tower = { version = "0.5", features = ["util"], default-features = false }
 tracing-futures = { version = "0.2.5", optional = true, default-features = false }
 sentry-core = { version = "0.34.0", optional = true, default-features = false }

README.md

@@ -34,7 +34,7 @@
 
 - Simple and predictable job handling model.
 - Jobs handlers with a macro free API.
-- Take full advantage of the [tower] ecosystem of
+- Take full advantage of the [`tower`] ecosystem of
   middleware, services, and utilities.
 - Runtime agnostic - Use tokio, smol etc.
 - Optional Web interface to help you manage your jobs.
@@ -59,43 +59,42 @@ To get started, just add to Cargo.toml
 
 ```toml
 [dependencies]
-apalis = { version = "0.5", features = ["redis"] } # Backends available: postgres, sqlite, mysql, amqp
+apalis = { version = "0.6" }
+apalis-redis = { version = "0.6" }
+# apalis-sql = { version = "0.6", features = ["postgres"] } # or mysql, sqlite
 ```
 
 ## Usage
 
 ```rust
 use apalis::prelude::*;
-use apalis::redis::RedisStorage;
+use apalis_redis::{RedisStorage, Config};
 use serde::{Deserialize, Serialize};
-use anyhow::Result;
 
 #[derive(Debug, Deserialize, Serialize)]
 struct Email {
     to: String,
 }
 
-impl Job for Email {
-    const NAME: &'static str = "apalis::Email";
-}
-
 /// A function that will be converted into a service.
 async fn send_email(job: Email, data: Data<usize>) -> Result<(), Error> {
   /// execute job
   Ok(())
 }
 
 #[tokio::main]
-async fn main() -> Result<()> {
+async fn main() -> {
     std::env::set_var("RUST_LOG", "debug");
     env_logger::init();
     let redis_url = std::env::var("REDIS_URL").expect("Missing env variable REDIS_URL");
-    let storage = RedisStorage::new(redis).await?;
+    let conn = apalis_redis::connect(redis_url).await.expect("Could not connect");
+    let storage = RedisStorage::new(conn);
     Monitor::new()
-        .register_with_count(2, {
+        .register({
             WorkerBuilder::new(format!("email-worker"))
+                .concurrency(2)
                 .data(0usize)
-                .with_storage(storage)
+                .backend(storage)
                 .build_fn(send_email)
         })
         .run()
@@ -122,17 +121,13 @@ async fn produce_route_jobs(storage: &RedisStorage<Email>) -> Result<()> {
 ## Feature flags
 
 - _tracing_ (enabled by default) — Support Tracing 👀
-- _redis_ — Include redis storage
-- _postgres_ — Include Postgres storage
-- _sqlite_ — Include SQlite storage
-- _mysql_ — Include MySql storage
-- _cron_ — Include cron job processing
 - _sentry_ — Support for Sentry exception and performance monitoring
 - _prometheus_ — Support Prometheus metrics
 - _retry_ — Support direct retrying jobs
 - _timeout_ — Support timeouts on jobs
 - _limit_ — 💪 Limit the amount of jobs
 - _filter_ — Support filtering jobs based on a predicate
+- _catch-panic_ - Catch panics that occur during execution
 
 ## Storage Comparison
 
@@ -214,5 +209,5 @@ See also the list of [contributors](https://github.com/geofmureithi/apalis/contr
 This project is licensed under the MIT License - see the [LICENSE.md](LICENSE.md) file for details
 
 [`tower::Service`]: https://docs.rs/tower/latest/tower/trait.Service.html
-[tower]: https://crates.io/crates/tower
+[`tower`]: https://crates.io/crates/tower
 [`actix`]: https://crates.io/crates/actix