Skip to content

Commit

Permalink
Update Workflow.cs
Browse files Browse the repository at this point in the history
  • Loading branch information
aelassas committed Feb 11, 2024
1 parent f50ebf4 commit e9657c1
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions src/netcore/Wexflow.Core/Workflow.cs
Original file line number Diff line number Diff line change
Expand Up @@ -235,6 +235,7 @@ public class Workflow
/// </summary>
public int RetryTimeout { get; private set; }

private readonly ManualResetEvent _event = new(true);
private readonly Queue<Job> _jobsQueue;
private Thread _thread;
private HistoryEntry _historyEntry;
Expand Down Expand Up @@ -1296,7 +1297,7 @@ private Task[] NodesToTasks(Node[] nodes)
var doTasks = NodesToTasks(@if.DoNodes);
var otherwiseTasks = NodesToTasks(@if.ElseNodes);

List<Task> ifTasks = new(doTasks);
List<Task> ifTasks = [..doTasks];
foreach (var task in otherwiseTasks)
{
if (ifTasks.All(t => t.Id != task.Id))
Expand Down Expand Up @@ -1783,8 +1784,6 @@ public bool Stop(string stoppedBy)
return false;
}

private readonly ManualResetEvent _event = new(true);

/// <summary>
/// If "unset" the thread will wait otherwise it will continue.
/// </summary>
Expand Down

0 comments on commit e9657c1

Please sign in to comment.