diff --git a/src/persistence/Elsa.Persistence.YesSql/Stores/YesSqlWorkflowInstanceStore.cs b/src/persistence/Elsa.Persistence.YesSql/Stores/YesSqlWorkflowInstanceStore.cs index 6ccef8304..2b25ab829 100644 --- a/src/persistence/Elsa.Persistence.YesSql/Stores/YesSqlWorkflowInstanceStore.cs +++ b/src/persistence/Elsa.Persistence.YesSql/Stores/YesSqlWorkflowInstanceStore.cs @@ -11,6 +11,7 @@ using Elsa.Persistence.YesSql.Services; using Microsoft.Extensions.Logging; using NodaTime; using YesSql; +using YesSql.Services; using IIdGenerator = Elsa.Services.IIdGenerator; namespace Elsa.Persistence.YesSql.Stores @@ -31,6 +32,7 @@ namespace Elsa.Persistence.YesSql.Stores { EntityIdSpecification spec => Query(session, x => x.InstanceId == spec.Id), WorkflowInstanceIdSpecification spec => Query(session, x => x.InstanceId == spec.Id), + WorkflowInstanceIdsSpecification spec => Query(session, x => x.InstanceId.IsIn(spec.WorkflowInstanceIds)), BlockingActivityTypeSpecification spec => Query(session, x => x.ActivityType == spec.ActivityType), _ => AutoMapSpecification(session, specification) };