Skip to content

perf: drop notify hints when queues are full - #7809

Open
Rohithmatham12 wants to merge 1 commit into
flyteorg:mainfrom
Rohithmatham12:codex/flyte-nonblocking-notify
Open

perf: drop notify hints when queues are full#7809
Rohithmatham12 wants to merge 1 commit into
flyteorg:mainfrom
Rohithmatham12:codex/flyte-nonblocking-notify

Conversation

@Rohithmatham12

Copy link
Copy Markdown

Summary

  • make runs-service NOTIFY enqueue non-blocking for both action and run updates
  • drop recoverable wakeup hints when the bounded queue is full instead of blocking write RPCs after the DB write has already succeeded
  • keep ctx cancellation logging and add regression coverage for full queues

Fixes #7757.

Testing

  • GOCACHE=/private/tmp/flyte-go-cache GOMODCACHE=/private/tmp/flyte-go-mod-cache go test ./runs/repository/impl -run 'TestNotify(Action|Run)Update_(PayloadWithSpecialChars|DropsWhenQueueFull)$'

@github-actions github-actions Bot added the flyte2 label Aug 8, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

perf: don't block action writes on the NOTIFY pump

1 participant