diff --git a/src/core/Elsa.Core/Extensions/WorkflowDefinitionManagerExtensions.cs b/src/core/Elsa.Core/Extensions/WorkflowDefinitionManagerExtensions.cs index 516158706..54ce96ecd 100644 --- a/src/core/Elsa.Core/Extensions/WorkflowDefinitionManagerExtensions.cs +++ b/src/core/Elsa.Core/Extensions/WorkflowDefinitionManagerExtensions.cs @@ -12,6 +12,9 @@ namespace Elsa.Extensions { public static IQuery QueryByIdAndVersion(this IWorkflowDefinitionManager manager, string workflowDefinitionId, VersionOptions versionOptions) => manager.Query(x => x.WorkflowDefinitionId == workflowDefinitionId).WithVersion(versionOptions); + + public static IQuery QueryByVersionId(this IWorkflowDefinitionManager manager, string workflowDefinitionVersionId) => + manager.Query(x => x.WorkflowDefinitionVersionId == workflowDefinitionVersionId); public static async Task GetAsync( this IWorkflowDefinitionManager manager, @@ -19,6 +22,12 @@ namespace Elsa.Extensions VersionOptions versionOptions, CancellationToken cancellationToken = default) => await manager.QueryByIdAndVersion(workflowDefinitionId, versionOptions).FirstOrDefaultAsync(); + + public static async Task GetByVersionIdAsync( + this IWorkflowDefinitionManager manager, + string workflowDefinitionVersionId, + CancellationToken cancellationToken = default) => + await manager.QueryByVersionId(workflowDefinitionVersionId).FirstOrDefaultAsync(); public static Task> ListByStatusAsync( this IWorkflowInstanceManager manager,