diff --git a/packages/runtime/runtimes/runtime-base/src/custom-read-model.ts b/packages/runtime/runtimes/runtime-base/src/custom-read-model.ts index 22b99d0bd..baf81cab6 100644 --- a/packages/runtime/runtimes/runtime-base/src/custom-read-model.ts +++ b/packages/runtime/runtimes/runtime-base/src/custom-read-model.ts @@ -140,6 +140,17 @@ const customReadModelMethods = { throw summaryError } } else if (events.length === 0) { + // Update event subscriber status to "not busy", + // otherwise no events will pass the busy check above + await eventstoreAdapter.ensureEventSubscriber({ + applicationName, + eventSubscriber, + status: { ...status, + busy: false + }, + updateOnly: true + }); + return { type: 'build-direct-invoke', payload: {