Skip to content

Commit 7970a6d

Browse files
committed
fix: reset duplicate-suppression state and stale step change on watch initialization
1 parent 66949ff commit 7970a6d

File tree

2 files changed

+16
-0
lines changed

2 files changed

+16
-0
lines changed

src/Configuration/Step.cs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,6 +83,11 @@ public override void Initialize()
8383
AddVariables();
8484
}
8585

86+
// Clear stale change state so OnNeedsCompleted doesn't use a previous run's change
87+
_change = null;
88+
_trigger = default;
89+
_processingCorrelationId = null;
90+
8691
base.Initialize();
8792
}
8893

src/Configuration/Watch.cs

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1057,6 +1057,17 @@ public override void OnCompleted(object? sender, TaskEventArgs e)
10571057
base.OnCompleted(sender, e);
10581058
}
10591059

1060+
public override void Initialize()
1061+
{
1062+
lock (_changeLock)
1063+
{
1064+
_lastChange = null;
1065+
_lastWriteTime = default;
1066+
_ignoreNextChange = false;
1067+
}
1068+
base.Initialize();
1069+
}
1070+
10601071
public override void OnNeedsCompleted(object? sender, TaskEventArgs e)
10611072
{
10621073
Logger.WriteLine(

0 commit comments

Comments
 (0)