Skip to content

Commit 18be33b

Browse files
committed
async issue
1 parent d3c5aca commit 18be33b

File tree

2 files changed

+8
-6
lines changed

2 files changed

+8
-6
lines changed

src/WorkflowCore/Services/BackgroundTasks/QueueConsumer.cs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -141,11 +141,11 @@ private async void Execute()
141141
task.Wait();
142142
}
143143

144-
private async Task ExecuteItem(string itemId)
144+
private Task ExecuteItem(string itemId)
145145
{
146146
try
147147
{
148-
await ProcessItem(itemId, _cancellationTokenSource.Token);
148+
ProcessItem(itemId, _cancellationTokenSource.Token).Wait();
149149
}
150150
catch (OperationCanceledException)
151151
{
@@ -155,6 +155,8 @@ private async Task ExecuteItem(string itemId)
155155
{
156156
Logger.LogError(default(EventId), ex, $"Error executing item {itemId} - {ex.Message}");
157157
}
158+
159+
return Task.CompletedTask;
158160
}
159161
}
160162
}

src/WorkflowCore/WorkflowCore.csproj

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,12 +15,12 @@
1515
<GenerateAssemblyCompanyAttribute>false</GenerateAssemblyCompanyAttribute>
1616
<GenerateAssemblyProductAttribute>false</GenerateAssemblyProductAttribute>
1717
<Description>Workflow Core is a light weight workflow engine targeting .NET Standard.</Description>
18-
<Version>3.2.3</Version>
19-
<AssemblyVersion>3.2.3.0</AssemblyVersion>
20-
<FileVersion>3.2.3.0</FileVersion>
18+
<Version>3.2.4</Version>
19+
<AssemblyVersion>3.2.4.0</AssemblyVersion>
20+
<FileVersion>3.2.4.0</FileVersion>
2121
<PackageReleaseNotes></PackageReleaseNotes>
2222
<PackageIconUrl>https://github.com/danielgerlag/workflow-core/raw/master/src/logo.png</PackageIconUrl>
23-
<PackageVersion>3.2.3</PackageVersion>
23+
<PackageVersion>3.2.4</PackageVersion>
2424
</PropertyGroup>
2525

2626
<ItemGroup>

0 commit comments

Comments
 (0)