Recurring With Compensation

[herme063]

I am executing Step 1-3 every 5min:

builder
	.StartWith(ctx => ExecutionResult.Next())
	.Recur(data => TimeSpan.FromMinutes(5), _ => false)
	.Do(rec => rec
		.StartWith<Step1>()
		.WaitFor("Step1Completed", _ => "0")
		.Then<Step2>()
		.WaitFor("Step2Completed", _ => "0")
		.Then<Step3>())
	.CompensateWith<CleanUp>();

I am testing a scenario where Step3 throws an exception, and I am expecting CleanUp to be called but it is not.

How do I execute a recurring tasks with compensation?

[herme063]

Alright, so it seems like I have to use saga:

builder
	.StartWith(ctx => ExecutionResult.Next())
	.Recur(data => TimeSpan.FromMinutes(5), _ => false)
	.Do(rec => rec
		.Saga(saga => saga
			.StartWith<Step1>()
			.WaitFor("Step1Completed", _ => "0")
			.Then<Step2>()
			.WaitFor("Step2Completed", _ => "0")
			.Then<Step3>())
		.CompensateWith<CleanUp>());

Cheers