Skip to content

Commit 24483ed

Browse files
committed
reseed rule
1 parent fc54f19 commit 24483ed

File tree

2 files changed

+11
-8
lines changed

2 files changed

+11
-8
lines changed

src/WorkflowCore/Services/BackgroundTasks/WorkflowConsumer.cs

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -92,11 +92,14 @@ private async Task SubscribeEvent(EventSubscription subscription, IPersistencePr
9292
Logger.LogDebug("Subscribing to event {0} {1} for workflow {2} step {3}", subscription.EventName, subscription.EventKey, subscription.WorkflowId, subscription.StepId);
9393

9494
await persistenceStore.CreateEventSubscription(subscription);
95-
var events = await persistenceStore.GetEvents(subscription.EventName, subscription.EventKey, subscription.SubscribeAsOf);
96-
foreach (var evt in events)
95+
if (subscription.EventName != Event.EventTypeActivity)
9796
{
98-
await persistenceStore.MarkEventUnprocessed(evt);
99-
await QueueProvider.QueueWork(evt, QueueType.Event);
97+
var events = await persistenceStore.GetEvents(subscription.EventName, subscription.EventKey, subscription.SubscribeAsOf);
98+
foreach (var evt in events)
99+
{
100+
await persistenceStore.MarkEventUnprocessed(evt);
101+
await QueueProvider.QueueWork(evt, QueueType.Event);
102+
}
100103
}
101104
}
102105

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.0.1</Version>
19-
<AssemblyVersion>3.0.1.0</AssemblyVersion>
20-
<FileVersion>3.0.1.0</FileVersion>
18+
<Version>3.0.2</Version>
19+
<AssemblyVersion>3.0.2.0</AssemblyVersion>
20+
<FileVersion>3.0.2.0</FileVersion>
2121
<PackageReleaseNotes></PackageReleaseNotes>
2222
<PackageIconUrl>https://github.com/danielgerlag/workflow-core/raw/master/src/logo.png</PackageIconUrl>
23-
<PackageVersion>3.0.1</PackageVersion>
23+
<PackageVersion>3.0.2</PackageVersion>
2424
</PropertyGroup>
2525

2626
<ItemGroup>

0 commit comments

Comments
 (0)