Skip to content

Commit 2ff5282

Browse files
Rollback changes for Even subscription
1 parent 96a6eda commit 2ff5282

File tree

1 file changed

+0
-11
lines changed

1 file changed

+0
-11
lines changed

src/WorkflowCore/Services/BackgroundTasks/WorkflowConsumer.cs

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -89,19 +89,8 @@ private async Task SubscribeEvent(EventSubscription subscription, IPersistencePr
8989
if (subscription.EventName != Event.EventTypeActivity)
9090
{
9191
var events = await persistenceStore.GetEvents(subscription.EventName, subscription.EventKey, subscription.SubscribeAsOf, cancellationToken);
92-
9392
foreach (var evt in events)
9493
{
95-
var locked = await _lockProvider.AcquireLock($"evt:{evt}", cancellationToken);
96-
int attempt = 0;
97-
while (locked && attempt < 10)
98-
{
99-
locked = await _lockProvider.AcquireLock($"evt:{evt}", cancellationToken);
100-
await Task.Delay(Options.IdleTime);
101-
102-
attempt++;
103-
}
104-
10594
await persistenceStore.MarkEventUnprocessed(evt, cancellationToken);
10695
await QueueProvider.QueueWork(evt, QueueType.Event);
10796
}

0 commit comments

Comments
 (0)