Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
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
463 changes: 436 additions & 27 deletions src/DurableTask.AzureStorage/Tracking/AzureTableTrackingStore.cs

Large diffs are not rendered by default.

10 changes: 8 additions & 2 deletions src/DurableTask.AzureStorage/Tracking/ITrackingStore.cs
Original file line number Diff line number Diff line change
Expand Up @@ -161,8 +161,14 @@ interface ITrackingStore
/// Used to update a state in the tracking store to pending whenever a rewind is initiated from the client
/// </summary>
/// <param name="instanceId">The instance being rewound</param>
/// <param name="cancellationToken">The token to monitor for cancellation requests. The default value is <see cref="CancellationToken.None"/>.</param>
Task UpdateStatusForRewindAsync(string instanceId, CancellationToken cancellationToken = default);
/// <param name="executionId">The execution being rewound</param>
/// <param name="rewindStartETag">The instance ETag captured before the rewind changed history.</param>
/// <param name="cancellationToken">The token to monitor for cancellation requests. The default value is <see cref="CancellationToken.None"/>.</param>
Task UpdateStatusForRewindAsync(
string instanceId,
string executionId,
ETag rewindStartETag,
CancellationToken cancellationToken = default);

/// <summary>
/// Used to update the instance status to "Terminated" when a pending orchestration is terminated.
Expand Down
6 changes: 5 additions & 1 deletion src/DurableTask.AzureStorage/Tracking/TrackingStoreBase.cs
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,11 @@ public virtual Task<PurgeHistoryResult> PurgeInstanceHistoryAsync(DateTime creat
public abstract Task<bool> SetNewExecutionAsync(ExecutionStartedEvent executionStartedEvent, ETag? eTag, string inputStatusOverride, CancellationToken cancellationToken = default);

/// <inheritdoc />
public virtual Task UpdateStatusForRewindAsync(string instanceId, CancellationToken cancellationToken = default)
public virtual Task UpdateStatusForRewindAsync(
string instanceId,
string executionId,
ETag rewindStartETag,
CancellationToken cancellationToken = default)
{
throw new NotSupportedException();
}
Expand Down
1,367 changes: 1,367 additions & 0 deletions test/DurableTask.AzureStorage.Tests/AzureStorageScenarioTests.cs

Large diffs are not rendered by default.

575 changes: 575 additions & 0 deletions test/DurableTask.AzureStorage.Tests/AzureTableTrackingStoreTest.cs

Large diffs are not rendered by default.

Loading
Loading