-
Notifications
You must be signed in to change notification settings - Fork 322
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
fix: rsources dropped jobs at processor #3905
Conversation
failedJobs, failedMetrics, failedCountMap := proc.getFailedEventJobs(response, commonMetaData, eventsByMessageID, transformer.EventFilterStage, transformationEnabled, trackingPlanEnabled) | ||
droppedJobs = append(droppedJobs, append(proc.getDroppedJobs(response, eventsToTransform), failedJobs...)...) | ||
eventsToTransform, successMetrics, successCountMap, successCountMetadataMap = proc.getDestTransformerEvents(response, commonMetaData, eventsByMessageID, destination, transformer.EventFilterStage, trackingPlanEnabled, transformationEnabled) |
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.
Was that change in order purposeful?
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.
yeah.
eventsToTransform
is modified after a call to proc.getDestTransformerEvents(...)
.
proc. getDroppedJobs
needs the total list of events sent to transformer/event filter.
@@ -2354,6 +2355,7 @@ func (proc *Handle) transformSrcDest( | |||
errorsPerDestID: procErrorJobsByDestID, | |||
reportMetrics: reportMetrics, | |||
routerDestIDs: routerDestIDs, | |||
droppedJobs: droppedJobs, |
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.
didn't we have a test for dropped jobs?
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.
missed this one😓
will post some more test cases soon.
Codecov ReportPatch coverage:
Additional details and impacted files@@ Coverage Diff @@
## master #3905 +/- ##
==========================================
- Coverage 69.16% 69.15% -0.02%
==========================================
Files 353 353
Lines 52903 52905 +2
==========================================
- Hits 36589 36584 -5
- Misses 13998 14001 +3
- Partials 2316 2320 +4
☔ View full report in Codecov by Sentry. |
17e1e58
to
cc07e71
Compare
Description
fix for recent r-sources dropped jobs PR
Linear Ticket
Ensure drop events are marked as failed in source [job-status endpoint]
Security