diff --git a/src/WorkflowCore/Services/BackgroundTasks/EventConsumer.cs b/src/WorkflowCore/Services/BackgroundTasks/EventConsumer.cs
index bdd730fca..a8c66e72a 100644
--- a/src/WorkflowCore/Services/BackgroundTasks/EventConsumer.cs
+++ b/src/WorkflowCore/Services/BackgroundTasks/EventConsumer.cs
@@ -36,6 +36,7 @@ protected override async Task ProcessItem(string itemId, CancellationToken cance
             if (!await _lockProvider.AcquireLock($"evt:{itemId}", cancellationToken))
             {
                 Logger.LogInformation($"Event locked {itemId}");
+                await QueueProvider.QueueWork(itemId, QueueType.Event);
                 return;
             }
             
@@ -107,6 +108,7 @@ private async Task<bool> SeedSubscription(Event evt, EventSubscription sub, Hash
             if (!await _lockProvider.AcquireLock(sub.WorkflowId, cancellationToken))
             {
                 Logger.LogInformation("Workflow locked {0}", sub.WorkflowId);
+                await QueueProvider.QueueWork(evt.Id, QueueType.Event);
                 return false;
             }
             
diff --git a/src/WorkflowCore/Services/BackgroundTasks/RunnablePoller.cs b/src/WorkflowCore/Services/BackgroundTasks/RunnablePoller.cs
index 6a6bdf79c..9d5edc575 100644
--- a/src/WorkflowCore/Services/BackgroundTasks/RunnablePoller.cs
+++ b/src/WorkflowCore/Services/BackgroundTasks/RunnablePoller.cs
@@ -93,7 +93,6 @@ private async void PollRunnables(object target)
                             if (_greylist.Contains($"evt:{item}"))
                             {
                                 _logger.LogDebug($"Got greylisted event {item}");
-                                _greylist.Add($"evt:{item}");
                                 continue;
                             }
                             _logger.LogDebug($"Got unprocessed event {item}");