Soenneker.Flywheel.Core 4.0.8

Soenneker.Flywheel.Core

Background jobs for .NET with Redis storage, retries, scheduling, and job chains.

Background work. Everything in view.

Queue a typed job, coordinate workers across instances, and follow each execution in the live Blazor dashboard.

The optional Flywheel Dashboard, shown with illustrative demo data.

Explore Flywheel · Dashboard · Run the demo

Setup

Requires .NET 10 and Redis 6.0.9 or newer. Add these packages to your app:

dotnet add package Soenneker.Flywheel.Core
dotnet add package Soenneker.Flywheel.Redis
dotnet add package Soenneker.Flywheel.Generators

Add PrivateAssets="all" to the Generators package reference in your project file.

Usage

In an ASP.NET Core app's Program.cs, register Flywheel and enqueue a job:

using Soenneker.Flywheel.Core.Attributes;
using Soenneker.Flywheel.Core.Registrars;
using Soenneker.Flywheel.Core.Services.Abstract;
using Soenneker.Flywheel.Generated;
using Soenneker.Flywheel.Redis;

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddFlywheel(options => options.Workers = 4)
    .AddRedis(options => options.ConnectionString = "localhost:6379")
    .AddGeneratedJobs();

var app = builder.Build();
var client = app.Services.GetRequiredService<IJobClient>();

await client.Enqueue(FlywheelJobs.MessageJobs_Write,
    new Message("Hello from Flywheel"));

await app.RunAsync();

public sealed record Message(string Text);

public sealed class MessageJobs(ILogger<MessageJobs> logger)
{
    [FlywheelJob("message.write.v1")]
    public Task Write(Message message, CancellationToken cancellationToken)
    {
        logger.LogInformation("{Message}", message.Text);
        return Task.CompletedTask;
    }
}

Enqueue returns after saving the job. Workers run it in the background. In other services, inject IJobClient to submit jobs.

Queue and schedule jobs

Use IJobClient for immediate, delayed, scheduled, recurring, cron, or chained jobs:

await client.Enqueue(FlywheelJobs.MessageJobs_Write, new Message("Later"),
    delay: TimeSpan.FromMinutes(10));

await client.Recurring("hourly-message", FlywheelJobs.MessageJobs_Write,
    new Message("Every hour"), TimeSpan.FromHours(1));

await client.Cron("weekday-message", FlywheelJobs.MessageJobs_Write,
    new Message("Good morning"), "0 9 * * MON-FRI",
    timeZoneId: "America/Chicago");

See IJobClient for the full API.

Jobs can run more than once; make handlers safe to retry and pass cancellation tokens to async work. Keep job names stable. Reusing a recurring or cron schedule ID leaves the existing schedule unchanged.

Related

• Redis: storage configuration.
• Generators: job method requirements.
• Dashboard: view jobs and logs.
• Demo: run a complete app.