Repository navigation
Allow tuning ingestion queue polling without increasing worker concurrency - #457
Open
ArnavAgrawal03 wants to merge 1 commit into
Open
ArnavAgrawal03 wants to merge 1 commit into
ArnavAgrawal03 wants to merge 1 commit into
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Ingestion workers currently check Redis every two seconds. With one worker and short text documents, this leaves the worker idle between jobs even when embedding finishes in about half a second.
Add
[worker].poll_delaytomorphik.toml, validate that it is positive and finite, and pass it to ARQ. The default stays at 2 seconds for existing deployments. Settingpoll_delay = 0.1reduces queue latency without increasingarq_max_jobsor the number of worker processes. The tradeoff is more frequent Redis reads while idle.Validation:
arq_max_jobs = 1.The real runs used the pinned official Core image
main-ce8fece7114db60d1d0f656f2320160de2514beawith the equivalent config/WorkerSettings change applied. Configuration unit tests run against this branch. This measures short text documents; it does not establish OCR/video throughput or large-manifest performance.After upgrading Core, opt in with:
Restart the ingestion worker after changing the setting.
Open in [code]smith · Need help on this PR? Tag
@codesmith-botwith what you need.