fix(workflow-engine): paginate all pages in ListActiveWorkflows helper, add pagination repo tests

- ListActiveWorkflows now iterates through all pages instead of returning
  only the first page, matching the "full list" contract callers expect
- Add 5 repository-level pagination tests verifying total count, complete
  non-overlapping iteration, empty results, out-of-range pages, and
  terminal workflow exclusion
- Update docs (README, AGENTS, presentation) to reflect paginated endpoint

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: danielskovli

src/Runtime/workflow-engine/AGENTS.md

@@ -33,7 +33,7 @@ Reusable class library for async workflow processing. Provides the core engine,
 
 - `GET /api/v1/namespaces` — list distinct namespaces
 - `POST /api/v1/{namespace}/workflows` — enqueue workflows, supports batch with dependency graphs
-- `GET /api/v1/{namespace}/workflows` — list active workflows (optional correlationId, label filters)
+- `GET /api/v1/{namespace}/workflows` — paginated list of active workflows (optional page, pageSize, correlationId, label filters)
 - `GET /api/v1/{namespace}/workflows/{workflowId:guid}` — get single workflow with all steps
 - `POST /api/v1/{namespace}/workflows/{workflowId:guid}/cancel` — request cancellation (idempotent)
 - `POST /api/v1/{namespace}/workflows/{workflowId:guid}/resume` — resume a terminal workflow for re-processing

src/Runtime/workflow-engine/README.md

@@ -54,7 +54,7 @@ See swagger for a [full list](http://localhost:8080/swagger) of endpoints. The m
 ```
 GET  /api/v1/namespaces                        (list distinct namespaces)
 POST /api/v1/{namespace}/workflows             (enqueue workflows)
-GET  /api/v1/{namespace}/workflows             (list active workflows)
+GET  /api/v1/{namespace}/workflows             (list active workflows, paginated via ?page & ?pageSize)
 GET  /api/v1/{namespace}/workflows/{id}        (get single workflow with steps)
 POST /api/v1/{namespace}/workflows/{id}/cancel (request cancellation)
 ```

src/Runtime/workflow-engine/docs/presentation-technical.md

@@ -264,7 +264,7 @@ When active workflows exceed the backpressure threshold, the engine returns **HT
 
 ### API
 - `GET /api/v1/{namespace}/workflows/{id}` — status, steps, errors, retry counts
-- `GET /api/v1/{namespace}/workflows` — list with filtering
+- `GET /api/v1/{namespace}/workflows?page=1&pageSize=25` — paginated list with filtering
 - Health endpoints: `/health`, `/health/ready`, `/health/live`
 
 ---

src/Runtime/workflow-engine/tests/WorkflowEngine.Repository.Tests/WorkflowQueryTests.cs

@@ -417,6 +417,139 @@ public async Task QueryWorkflowsWithCount_NoMatches_ReturnsEmptyListAndZeroCount
         Assert.Equal(0, totalCount);
     }
 
+    // ── GetActiveWorkflowsPaginated ──────────────────────────────────────
+
+    [Fact]
+    public async Task GetActiveWorkflowsPaginated_ReturnsCorrectTotalCount()
+    {
+        await using var context = fixture.CreateDbContext();
+        var repo = fixture.CreateRepository();
+        var ns = Guid.NewGuid().ToString("N");
+
+        for (var i = 0; i < 7; i++)
+            await WorkflowTestHelper.InsertAndSetStatus(repo, context, PersistentItemStatus.Enqueued, ns: ns);
+
+        var (workflows, totalCount) = await repo.GetActiveWorkflowsPaginated(
+            page: 1,
+            pageSize: 3,
+            ns: ns,
+            cancellationToken: TestContext.Current.CancellationToken
+        );
+
+        Assert.Equal(7, totalCount);
+        Assert.Equal(3, workflows.Count);
+    }
+
+    [Fact]
+    public async Task GetActiveWorkflowsPaginated_IteratingAllPages_ReturnsCompleteNonOverlappingSet()
+    {
+        // Arrange — insert 13 workflows, page size 5 → 3 pages (5, 5, 3)
+        await using var context = fixture.CreateDbContext();
+        var repo = fixture.CreateRepository();
+        var ns = Guid.NewGuid().ToString("N");
+        const int totalWorkflows = 13;
+        const int pageSize = 5;
+
+        var insertedIds = new HashSet<Guid>();
+        for (var i = 0; i < totalWorkflows; i++)
+        {
+            var wf = await WorkflowTestHelper.InsertAndSetStatus(repo, context, PersistentItemStatus.Enqueued, ns: ns);
+            insertedIds.Add(wf.DatabaseId);
+        }
+
+        // Act — iterate through all pages
+        var collectedIds = new List<Guid>();
+        var page = 1;
+        int reportedTotal;
+
+        while (true)
+        {
+            var (workflows, totalCount) = await repo.GetActiveWorkflowsPaginated(
+                page: page,
+                pageSize: pageSize,
+                ns: ns,
+                cancellationToken: TestContext.Current.CancellationToken
+            );
+
+            reportedTotal = totalCount;
+            collectedIds.AddRange(workflows.Select(w => w.DatabaseId));
+
+            var totalPages = (int)Math.Ceiling((double)totalCount / pageSize);
+            if (page >= totalPages)
+                break;
+
+            page++;
+        }
+
+        // Assert
+        Assert.Equal(totalWorkflows, reportedTotal);
+        Assert.Equal(totalWorkflows, collectedIds.Count);
+        Assert.Equal(totalWorkflows, collectedIds.Distinct().Count()); // no duplicates
+        Assert.True(insertedIds.SetEquals(collectedIds)); // complete set
+    }
+
+    [Fact]
+    public async Task GetActiveWorkflowsPaginated_EmptyResult_ReturnsZeroTotalCount()
+    {
+        var repo = fixture.CreateRepository();
+        var ns = Guid.NewGuid().ToString("N");
+
+        var (workflows, totalCount) = await repo.GetActiveWorkflowsPaginated(
+            page: 1,
+            pageSize: 10,
+            ns: ns,
+            cancellationToken: TestContext.Current.CancellationToken
+        );
+
+        Assert.Empty(workflows);
+        Assert.Equal(0, totalCount);
+    }
+
+    [Fact]
+    public async Task GetActiveWorkflowsPaginated_PageBeyondLastPage_ReturnsEmptyDataWithCorrectTotal()
+    {
+        await using var context = fixture.CreateDbContext();
+        var repo = fixture.CreateRepository();
+        var ns = Guid.NewGuid().ToString("N");
+
+        for (var i = 0; i < 3; i++)
+            await WorkflowTestHelper.InsertAndSetStatus(repo, context, PersistentItemStatus.Enqueued, ns: ns);
+
+        var (workflows, totalCount) = await repo.GetActiveWorkflowsPaginated(
+            page: 99,
+            pageSize: 10,
+            ns: ns,
+            cancellationToken: TestContext.Current.CancellationToken
+        );
+
+        Assert.Empty(workflows);
+        Assert.Equal(3, totalCount);
+    }
+
+    [Fact]
+    public async Task GetActiveWorkflowsPaginated_ExcludesTerminalWorkflows()
+    {
+        await using var context = fixture.CreateDbContext();
+        var repo = fixture.CreateRepository();
+        var ns = Guid.NewGuid().ToString("N");
+
+        await WorkflowTestHelper.InsertAndSetStatus(repo, context, PersistentItemStatus.Enqueued, ns: ns);
+        await WorkflowTestHelper.InsertAndSetStatus(repo, context, PersistentItemStatus.Enqueued, ns: ns);
+        await WorkflowTestHelper.InsertAndSetStatus(repo, context, PersistentItemStatus.Completed, ns: ns);
+        await WorkflowTestHelper.InsertAndSetStatus(repo, context, PersistentItemStatus.Failed, ns: ns);
+
+        var (workflows, totalCount) = await repo.GetActiveWorkflowsPaginated(
+            page: 1,
+            pageSize: 25,
+            ns: ns,
+            cancellationToken: TestContext.Current.CancellationToken
+        );
+
+        Assert.Equal(2, totalCount);
+        Assert.Equal(2, workflows.Count);
+        Assert.All(workflows, wf => Assert.Equal(PersistentItemStatus.Enqueued, wf.Status));
+    }
+
     // ── Helpers ─────────────────────────────────────────────────────────
 
     private static async Task SetUpdatedAt(

src/Runtime/workflow-engine/tests/WorkflowEngine.TestKit/EngineApiClient.cs

@@ -215,13 +215,24 @@ public async Task<PaginatedResponse<WorkflowStatusResponse>> ListActiveWorkflows
     }
 
     /// <summary>
-    /// Lists active workflows and returns either a parsed result or an empty list on 204 No Content.
-    /// Convenience wrapper around <see cref="ListActiveWorkflowsPaginated"/> that returns just the data.
+    /// Lists all active workflows by iterating through every page.
+    /// Convenience wrapper around <see cref="ListActiveWorkflowsPaginated"/> that returns the full dataset.
     /// </summary>
     public async Task<List<WorkflowStatusResponse>> ListActiveWorkflows(string? ns = null)
     {
-        var result = await ListActiveWorkflowsPaginated(ns: ns);
-        return [.. result.Data];
+        var all = new List<WorkflowStatusResponse>();
+        var page = 1;
+
+        while (true)
+        {
+            var result = await ListActiveWorkflowsPaginated(page: page, ns: ns);
+            all.AddRange(result.Data);
+
+            if (result.TotalPages == 0 || page >= result.TotalPages)
+                return all;
+
+            page++;
+        }
     }
 
     /// <summary>