diff --git a/x-pack/plugins/ingest_manager/server/services/agents/checkin/state_new_actions.ts b/x-pack/plugins/ingest_manager/server/services/agents/checkin/state_new_actions.ts index 8f586420c3ecb7..4122677a615ca8 100644 --- a/x-pack/plugins/ingest_manager/server/services/agents/checkin/state_new_actions.ts +++ b/x-pack/plugins/ingest_manager/server/services/agents/checkin/state_new_actions.ts @@ -53,11 +53,15 @@ function getInternalUserSOClient() { } function createNewActionsSharedObservable(): Observable { - const internalSOClient = getInternalUserSOClient(); + let lastTimestamp = new Date().toISOString(); return timer(0, AGENT_UPDATE_ACTIONS_INTERVAL_MS).pipe( switchMap(() => { - return from(getNewActionsSince(internalSOClient, new Date().toISOString())); + const internalSOClient = getInternalUserSOClient(); + + const timestamp = lastTimestamp; + lastTimestamp = new Date().toISOString(); + return from(getNewActionsSince(internalSOClient, timestamp)); }), shareReplay({ refCount: true, bufferSize: 1 }) );