Optimize workflow tests: Add configurable delays like JobGateway pattern

Co-authored-by: devstress <30769729+devstress@users.noreply.github.com>

Author: Copilot

FlinkDotNet/FlinkDotNet.JobManager.Tests/Workflows/FlinkJobWorkflowTestBase.cs

@@ -0,0 +1,34 @@
+//  Licensed to the Apache Software Foundation (ASF) under one
+//  or more contributor license agreements.  See the NOTICE file
+//  distributed with this work for additional information
+//  regarding copyright ownership.  The ASF licenses this file
+//  to you under the Apache License, Version 2.0 (the
+//  "License"); you may not use this file except in compliance
+//  with the License.  You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+//  Unless required by applicable law or agreed to in writing, software
+//  distributed under the License is distributed on an "AS IS" BASIS,
+//  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//  See the License for the specific language governing permissions and
+//  limitations under the License.
+
+using FlinkDotNet.JobManager.Workflows;
+
+namespace FlinkDotNet.JobManager.Tests.Workflows;
+
+/// <summary>
+/// Base class for FlinkJobWorkflow tests providing common setup for fast test execution.
+/// Optimizes workflow delays to 1ms for rapid test execution (following JobGateway pattern).
+/// </summary>
+public abstract class FlinkJobWorkflowTestBase
+{
+    public FlinkJobWorkflowTestBase()
+    {
+        // Set workflow delays to 1ms for fast test execution
+        // This reduces test execution time from 5+ seconds per test to ~100ms
+        // Following the same optimization pattern as JobGateway tests
+        FlinkJobWorkflow.TaskMonitoringDelay = TimeSpan.FromMilliseconds(1);
+    }
+}

FlinkDotNet/FlinkDotNet.JobManager.Tests/Workflows/FlinkJobWorkflowTests.cs

@@ -25,8 +25,9 @@ namespace FlinkDotNet.JobManager.Tests.Workflows;
 /// <summary>
 /// Tests for FlinkJobWorkflow - Temporal workflow orchestration
 /// Phase 4: Temporal Integration - TDD Tests
+/// Optimized for fast execution (1ms delays instead of 5s)
 /// </summary>
-public class FlinkJobWorkflowTests
+public class FlinkJobWorkflowTests : FlinkJobWorkflowTestBase
 {
     [Fact]
     public async Task ExecuteJobAsync_SimpleJobGraph_CompletesSuccessfully()

FlinkDotNet/FlinkDotNet.JobManager/Workflows/FlinkJobWorkflow.cs

@@ -28,6 +28,11 @@ namespace FlinkDotNet.JobManager.Workflows;
 [Workflow]
 public class FlinkJobWorkflow
 {
+    /// <summary>
+    /// Configurable delay for task execution monitoring (can be overridden in tests for fast execution)
+    /// </summary>
+    public static TimeSpan TaskMonitoringDelay { get; set; } = TimeSpan.FromSeconds(5);
+
     private JobExecutionState _currentState = JobExecutionState.Created;
     private List<string> _deployedTasks = new();
     private Dictionary<string, ExecutionState> _taskStates = new();
@@ -216,7 +221,8 @@ private async Task MonitorTaskExecutionAsync(string jobId)
 
         // Wait for all tasks to complete or fail
         // In production, this would be event-driven based on activity completion
-        await Workflow.DelayAsync(TimeSpan.FromSeconds(5));
+        // Use configurable delay to allow fast test execution (1ms in tests, 5s in production)
+        await Workflow.DelayAsync(TaskMonitoringDelay);
 
         // Update task states based on job state
         foreach (string taskId in this._deployedTasks)