diff --git a/src/modules/Elsa.Hangfire/Jobs/ExecuteBackgroundActivityJob.cs b/src/modules/Elsa.Hangfire/Jobs/ExecuteBackgroundActivityJob.cs index 0909cba4c..8af4fb8da 100644 --- a/src/modules/Elsa.Hangfire/Jobs/ExecuteBackgroundActivityJob.cs +++ b/src/modules/Elsa.Hangfire/Jobs/ExecuteBackgroundActivityJob.cs @@ -19,4 +19,14 @@ public class ExecuteBackgroundActivityJob(IBackgroundActivityInvoker backgroundA using var scope = tenantAccessor.PushContext(tenant); await backgroundActivityInvoker.ExecuteAsync(scheduledBackgroundActivity, cancellationToken); } + + /// + /// Executes the job. + /// + [Obsolete("Use the other overload.")] + [UsedImplicitly] + public async Task ExecuteAsync(ScheduledBackgroundActivity scheduledBackgroundActivity, CancellationToken cancellationToken = default) + { + await backgroundActivityInvoker.ExecuteAsync(scheduledBackgroundActivity, cancellationToken); + } } \ No newline at end of file diff --git a/src/modules/Elsa.Hangfire/Jobs/ResumeWorkflowJob.cs b/src/modules/Elsa.Hangfire/Jobs/ResumeWorkflowJob.cs index 0290bb702..aac9941e2 100644 --- a/src/modules/Elsa.Hangfire/Jobs/ResumeWorkflowJob.cs +++ b/src/modules/Elsa.Hangfire/Jobs/ResumeWorkflowJob.cs @@ -3,6 +3,7 @@ using Elsa.Scheduling; using Elsa.Workflows.Runtime; using Elsa.Workflows.Runtime.Messages; using Hangfire; +using JetBrains.Annotations; namespace Elsa.Hangfire.Jobs; @@ -34,4 +35,19 @@ public class ResumeWorkflowJob(IWorkflowRuntime workflowRuntime, ITenantFinder t }; await client.RunInstanceAsync(runRequest, cancellationToken); } + + [Obsolete("Use the other overload.")] + [UsedImplicitly] + public async Task ExecuteAsync(string taskName, ScheduleExistingWorkflowInstanceRequest request, CancellationToken cancellationToken) + { + var client = await workflowRuntime.CreateClientAsync(request.WorkflowInstanceId, cancellationToken); + var runRequest = new RunWorkflowInstanceRequest + { + BookmarkId = request.BookmarkId, + ActivityHandle = request.ActivityHandle, + Input = request.Input, + Properties = request.Properties + }; + await client.RunInstanceAsync(runRequest, cancellationToken); + } } diff --git a/src/modules/Elsa.Hangfire/Jobs/RunWorkflowJob.cs b/src/modules/Elsa.Hangfire/Jobs/RunWorkflowJob.cs index 9520abc58..94a979e28 100644 --- a/src/modules/Elsa.Hangfire/Jobs/RunWorkflowJob.cs +++ b/src/modules/Elsa.Hangfire/Jobs/RunWorkflowJob.cs @@ -3,6 +3,7 @@ using Elsa.Scheduling; using Elsa.Workflows.Runtime; using Elsa.Workflows.Runtime.Messages; using Hangfire; +using JetBrains.Annotations; namespace Elsa.Hangfire.Jobs; @@ -36,4 +37,21 @@ public class RunWorkflowJob(IWorkflowRuntime workflowRuntime, ITenantFinder tena }; await client.CreateAndRunInstanceAsync(createAndRunRequest, cancellationToken); } + + [Obsolete("Use the other overload.")] + [UsedImplicitly] + public async Task ExecuteAsync(string taskName, ScheduleNewWorkflowInstanceRequest request, CancellationToken cancellationToken) + { + var client = await workflowRuntime.CreateClientAsync(cancellationToken); + var createAndRunRequest = new CreateAndRunWorkflowInstanceRequest + { + WorkflowDefinitionHandle = request.WorkflowDefinitionHandle, + TriggerActivityId = request.TriggerActivityId, + CorrelationId = request.CorrelationId, + Input = request.Input, + Properties = request.Properties, + ParentId = request.ParentId + }; + await client.CreateAndRunInstanceAsync(createAndRunRequest, cancellationToken); + } } \ No newline at end of file