SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Wrap Strategy property of Delay activity

Browse source
This commit is contained in:
Sipke Schoorstra 2023-02-16 19:59:30 +01:00
parent a580fd77f1
commit a62956b2c0
3 changed files with 9 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/modules/Elsa.Scheduling/Activities/Delay.cs
View file

@ -44,7 +44,7 @@ public class Delay : CodeActivity
[CallerFilePath] string? source = default, [CallerLineNumber] int? line = default) : base(source, line)
{
TimeSpan = timeSpan;
Strategy = blockingStrategy;
Strategy = new(blockingStrategy);
}
/// <inheritdoc />
@ -54,17 +54,17 @@ public class Delay : CodeActivity
[CallerFilePath] string? source = default, [CallerLineNumber] int? line = default) : base(source, line)
{
TimeSpan = new Input<TimeSpan>(timeSpan);
Strategy = blockingStrategy;
Strategy = new(blockingStrategy);
}
/// <inheritdoc />
public Delay(
Variable<TimeSpan> timeSpan,
DelayBlockingStrategy blockingStrategy = DelayBlockingStrategy.NonBlocking,
DelayBlockingStrategy blockingStrategy = DelayBlockingStrategy.Blocking,
[CallerFilePath] string? source = default, [CallerLineNumber] int? line = default) : base(source, line)
{
TimeSpan = new Input<TimeSpan>(timeSpan);
Strategy = blockingStrategy;
Strategy = new(blockingStrategy);
}
/// <summary>
@ -75,7 +75,8 @@ public class Delay : CodeActivity
/// <summary>
/// A value controlling whether the delay should happen in-process (synchronously or out of process (asynchronously).
/// </summary>
[Input] public DelayBlockingStrategy Strategy { get; set; } = DelayBlockingStrategy.NonBlocking;
[Input(Description = "")]
public Input<DelayBlockingStrategy> Strategy { get; set; } = new(DelayBlockingStrategy.Blocking);
/// <summary>
/// The threshold used by the <see cref="DelayBlockingStrategy.Auto"/>
@ -86,7 +87,7 @@ public class Delay : CodeActivity
protected override async ValueTask ExecuteAsync(ActivityExecutionContext context)
{
var timeSpan = context.ExpressionExecutionContext.Get(TimeSpan);
var blockingMode = Strategy;
var blockingMode = Strategy.Get(context);
switch (blockingMode)
{

2
src/samples/console/Elsa.Samples.LoopingWorkflows/Workflows/ForEachWorkflow.cs
View file

@ -31,7 +31,7 @@ public static class ForEachWorkflow
{
// The strategy determines whether the workflow should suspend or wait synchronously.
// For console applications without a host, long-running workflows aren't supported, so we use the Blocking strategy.
Strategy = DelayBlockingStrategy.Blocking,
Strategy = new(DelayBlockingStrategy.Blocking),
TimeSpan = new Input<TimeSpan>(TimeSpan.FromMilliseconds(250))
}
}

2
src/samples/console/Elsa.Samples.LoopingWorkflows/Workflows/ForWorkflow.cs
View file

@ -31,7 +31,7 @@ public static class ForWorkflow
{
// The strategy determines whether the workflow should suspend or wait synchronously.
// For console applications without a host, long-running workflows aren't supported, so we use the Blocking strategy.
Strategy = DelayBlockingStrategy.Blocking,
Strategy = new(DelayBlockingStrategy.Blocking),
TimeSpan = new Input<TimeSpan>(TimeSpan.FromSeconds(1))
}
}