-
Notifications
You must be signed in to change notification settings - Fork 8.2k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[Fleet] Fix agent action observable for long polling #81376
[Fleet] Fix agent action observable for long polling #81376
Conversation
Pinging @elastic/ingest-management (Team:Ingest Management) |
@@ -247,11 +247,16 @@ export async function getNewActionsSince( | |||
nodeTypes.literal.buildNode(false), | |||
]) | |||
), | |||
nodeTypes.function.buildNodeWithArgumentNodes('is', [ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
added this condition to not fetch POLICY_CHANGE
here, (the action was filtered in the code after) but in my opinion the earlier we filter it the better it is
b177026
to
12f99ce
Compare
💚 Build SucceededMetrics [docs]
History
To update your PR or re-run it, just comment with: |
* master: (63 commits) [KP] Fix Headers timeout issue (elastic#81140) [ML] Functional tests - stabilize typing with checks service method (elastic#81338) tabify - support docs (elastic#80351) [Security Solution][Detections] Look-back time logic fix (elastic#81383) [Workplace Search] Add top-level tests for Groups (elastic#81215) [Fleet] Fix agent action observable for long polling (elastic#81376) [Maps] fix feature tooltip remains open when zoom level change hides layer (elastic#81373) skip flaky suite (elastic#78689) chore(NA): add spec-to-console and plugin-helpers as devOnly dependencies (elastic#81357) Ensure some data is returned (elastic#81375) Change dumb-init to tini (elastic#81126) [Reporting/Tech Debt] Convert PdfMaker class to TypeScript (elastic#81242) Use Storybook Controls instead of Knobs (elastic#80705) [junit] make sure that report paths are unique (elastic#81255) bump elastic/elasticsearch-js version to 7.10.0-rc1 (elastic#81288) run ssl tests on CI (elastic#81320) Fix alert defaults (elastic#81207) [ML] DF Analytics wizard: ensure user can set mml manually or select to use given estimate (elastic#81078) Add UI notifier to indicate secret fields and to remember / reenter values (elastic#80657) [Monitoring] Use async/await (elastic#81200) ...
Summary
Partially resolve #80930
The policy reassign is relying on fetching
INTERNAL_POLICY_REASSIGN
action, but looks like there is some race condition that can cause the action to not been fetched.This PR fix it and add some unit test.
Details
switchMap
to anexhaustMap
so if the functiongetNewActionsSince
take more than 5 seconds we do not loose actions.getNewActionsSince
instead of the last time we fetched data, as it's looks like thecreated_at
date will be available to search in elastic after the document is created in Kibana