Skip to content

Feature: Add async/await support to WorkflowManager #6

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
quickattach0-tech merged 1 commit into from
Jan 25, 2026
Merged

Feature: Add async/await support to WorkflowManager #6

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
84 changes: 84 additions & 0 deletions DeepLearningProtocol/Workflow.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -119,6 +119,30 @@ public void StartStage(int stageNumber, string name, string description)
LogStageEvent(stage, $"Stage {stageNumber}: {name} started");
}

/// <summary>
/// Start a new workflow stage (async version)
/// </summary>
public async Task StartStageAsync(int stageNumber, string name, string description)
{
await Task.Run(() => StartStage(stageNumber, name, description));
}

/// <summary>
/// Complete current workflow stage (async version)
/// </summary>
public async Task CompleteStageAsync(string stageName, bool success, string summary = "")
{
await Task.Run(() => CompleteStage(stageName, success, summary));
}

/// <summary>
/// Add log entry to current stage (async version)
/// </summary>
public async Task AddLogAsync(string stageName, string message)
{
await Task.Run(() => AddLog(stageName, message));
}

/// <summary>
/// Complete current workflow stage
/// </summary>
Expand Down Expand Up @@ -288,6 +312,14 @@ public void SaveWorkflowToFile(string workflowName)
}
}

/// <summary>
/// Save workflow to JSON file with error handling (async version)
/// </summary>
public async Task SaveWorkflowToFileAsync(string workflowName)
{
await Task.Run(() => SaveWorkflowToFile(workflowName));
}

/// <summary>
/// Get pipeline configuration for CI/CD
/// </summary>
Expand Down Expand Up @@ -447,6 +479,30 @@ public void ExecuteDevelopmentWorkflow()
_logger(_workflowManager.GetWorkflowSummary());
}

/// <summary>
/// Execute development workflow (async version)
/// </summary>
public async Task ExecuteDevelopmentWorkflowAsync()
{
_logger("Starting Development Workflow (Async)...");
_workflowManager.SetState(WorkflowManager.WorkflowState.InProgress);

await _workflowManager.StartStageAsync(1, "Feature Development", "Code implementation and feature development");
await Task.Delay(1000);
await _workflowManager.CompleteStageAsync("Feature Development", true, "Feature implemented successfully");

await _workflowManager.StartStageAsync(2, "Unit Testing", "Local unit test execution");
await Task.Delay(1000);
await _workflowManager.CompleteStageAsync("Unit Testing", true, "All tests passed (8/8)");

await _workflowManager.StartStageAsync(3, "Code Review", "Peer code review");
await Task.Delay(1000);
await _workflowManager.CompleteStageAsync("Code Review", true, "Approved for merge");

_workflowManager.SetState(WorkflowManager.WorkflowState.Completed);
_logger(_workflowManager.GetWorkflowSummary());
}

/// <summary>
/// Execute CI/CD pipeline workflow
/// </summary>
Expand Down Expand Up @@ -474,5 +530,33 @@ public void ExecuteCIPipelineWorkflow()
_workflowManager.SetState(WorkflowManager.WorkflowState.Completed);
_logger(_workflowManager.GetWorkflowSummary());
}

/// <summary>
/// Execute CI/CD pipeline workflow (async version)
/// </summary>
public async Task ExecuteCIPipelineWorkflowAsync()
{
_logger("Starting CI/CD Pipeline Workflow (Async)...");
_workflowManager.SetState(WorkflowManager.WorkflowState.InProgress);

await _workflowManager.StartStageAsync(1, "Build Stage", "Debug/Release build compilation");
await Task.Delay(1500);
await _workflowManager.CompleteStageAsync("Build Stage", true, "Build successful - 0 errors");

await _workflowManager.StartStageAsync(2, "Testing Stage", "Unit test execution with coverage");
await Task.Delay(2000);
await _workflowManager.CompleteStageAsync("Testing Stage", true, "8/8 tests passed");

await _workflowManager.StartStageAsync(3, "Code Quality Stage", "Code style and quality checks");
await Task.Delay(1000);
await _workflowManager.CompleteStageAsync("Code Quality Stage", true, "Quality standards met");

await _workflowManager.StartStageAsync(4, "Artifact Publishing", "Build artifact storage");
await Task.Delay(500);
await _workflowManager.CompleteStageAsync("Artifact Publishing", true, "Artifacts published (30d retention)");

_workflowManager.SetState(WorkflowManager.WorkflowState.Completed);
_logger(_workflowManager.GetWorkflowSummary());
}
}
}
Loading