Philiprehberger.TaskDependencyRunner 0.3.1

Philiprehberger.TaskDependencyRunner

Lightweight task runner with dependency graph resolution and parallel execution.

Installation

dotnet add package Philiprehberger.TaskDependencyRunner

Usage

using Philiprehberger.TaskDependencyRunner;

var graph = new TaskGraph()
    .Add("clean",   () => Console.WriteLine("Cleaning..."))
    .Add("restore", () => Console.WriteLine("Restoring packages..."), "clean")
    .Add("build",   () => Console.WriteLine("Building..."),           "restore")
    .Add("test",    () => Console.WriteLine("Running tests..."),       "build")
    .Add("pack",    () => Console.WriteLine("Packing..."),             "build");

await graph.RunAsync();

Typed task results

Tasks can produce results that downstream tasks consume via ITaskContext:

using Philiprehberger.TaskDependencyRunner;

var graph = new TaskGraph()
    .Add<int>("fetch-count", _ => Task.FromResult(42))
    .Add<string>("format", ctx =>
    {
        var count = ctx.GetResult<int>("fetch-count");
        return Task.FromResult($"Total: {count}");
    }, "fetch-count")
    .Add("print", (ctx) =>
    {
        Console.WriteLine(ctx.GetResult<string>("format"));
        return Task.CompletedTask;
    }, "format");

await graph.RunAsync();

// Access results after execution
var formatted = (string)graph.TaskResults["format"]!;

Per-task timeout

Set a timeout on individual tasks. If the timeout elapses, a TaskTimeoutException is thrown:

var graph = new TaskGraph()
    .Add("fast", () => Console.WriteLine("Done"))
    .Add("slow", async () => await Task.Delay(10_000), timeout: TimeSpan.FromSeconds(2));

try
{
    await graph.RunAsync();
}
catch (TaskTimeoutException ex)
{
    Console.WriteLine($"{ex.TaskName} timed out");
}

Progress reporting

Track execution progress with the IProgressReporter interface:

var graph = new TaskGraph
{
    ProgressReporter = new ConsoleProgressReporter()
};

graph
    .Add("clean", () => { })
    .Add("build", () => { }, "clean")
    .Add("test",  () => { }, "build");

await graph.RunAsync();
// Output:
// [START] clean
// [DONE]  clean (1ms)
// [START] build
// [DONE]  build (0ms)
// [START] test
// [DONE]  test (0ms)

Dry-run mode

Validate the graph and inspect the execution plan without running any tasks:

var graph = new TaskGraph()
    .Add("a", () => { })
    .Add("b", () => { })
    .Add("c", () => { }, "a", "b")
    .Add("d", () => { }, "c");

var plan = graph.DryRun();

foreach (var (batch, i) in plan.Batches.Select((b, i) => (b, i)))
    Console.WriteLine($"Batch {i}: {string.Join(", ", batch)}");
// Batch 0: a, b
// Batch 1: c
// Batch 2: d

Max concurrency

Limit how many tasks run in parallel:

var graph = new TaskGraph { MaxConcurrency = 2 };

graph
    .Add("a", async () => await Task.Delay(100))
    .Add("b", async () => await Task.Delay(100))
    .Add("c", async () => await Task.Delay(100));

await graph.RunAsync();

Error handling

// Circular dependency
var bad = new TaskGraph()
    .Add("a", () => { }, "b")
    .Add("b", () => { }, "a");
// Throws CircularDependencyException

// Missing dependency
var missing = new TaskGraph()
    .Add("a", () => { }, "nonexistent");
// Throws MissingDependencyException

API

TaskGraph

ITaskContext

IProgressReporter

ExecutionPlan

Exceptions

Development

dotnet build src/Philiprehberger.TaskDependencyRunner.csproj --configuration Release

Support

If you find this project useful:

⭐ Star the repo

🐛 Report issues

💡 Suggest features

❤️ Sponsor development

🌐 All Open Source Projects

💻 GitHub Profile

🔗 LinkedIn Profile

License

MIT