-
Notifications
You must be signed in to change notification settings - Fork 15
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
refactor(bouncer): multicast subscriptions #4980
Conversation
Codecov ReportAll modified and coverable lines are covered by tests ✅
Additional details and impacted files@@ Coverage Diff @@
## main #4980 +/- ##
======================================
- Coverage 71% 71% -0%
======================================
Files 429 429
Lines 74061 73938 -123
Branches 74061 73938 -123
======================================
- Hits 52934 52730 -204
- Misses 18294 18369 +75
- Partials 2833 2839 +6 ☔ View full report in Codecov by Sentry. |
e7dc4e5
to
fef9b00
Compare
65df0ed
to
4cbc471
Compare
console.log(`Withdrawal requested, egressId: ${withdrawalRequestedEvent.data.egressId}`); | ||
const BatchBroadcastRequestedEvent = await observeEvent(':BatchBroadcastRequested', { |
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 just testing an implementation detail that's not relevant, and was the cause of flakiness as it introduces a race condition.
* refactor(bouncer): multicast subscriptions * reuse subscriptions * remove logs * tmp: run upgrade-test * fix: depends on try-runtime * add logs * more logs and shorten timeout * fix async issue * restore timeout * fix: start observing before submitting request * fix: remove awaiting on batch broadcast requested * remove logs * revert running upgrade-test on every push --------- Co-authored-by: kylezs <zsembery.kyle@gmail.com>
Pull Request
Closes: PRO-xxx
Checklist
Please conduct a thorough self-review before opening the PR.
Summary
We were creating 157 separate subscriptions.... this just creates one and multicasts it, hopefully eliminating the excessive memory usage we've been seeing.