Skip to content

fix(collector): isolate and drain complete undrained LOB segments - #1156

Open
proerror77 wants to merge 2 commits into
mainfrom
cursor/collector-recovery-complete-segments-1729
Open

fix(collector): isolate and drain complete undrained LOB segments#1156
proerror77 wants to merge 2 commits into
mainfrom
cursor/collector-recovery-complete-segments-1729

Conversation

@proerror77

@proerror77 proerror77 commented Sep 12, 2026

Copy link
Copy Markdown
Owner

Change

LOB recovery isolate now queues rotated complete undrained segments (*.manifest.json, *.jsonl.zst, ._SUCCESS), not only incomplete *.jsonl.part / *.zst.tmp. After archiver death, those sealed local segments had no drain path except the 600s/900s upload-staleness monitor.

Leftover *.uploaded-cleanup.json markers are not undrained segments. Isolate leaves them on the live spool for the production archiver. Drain of a cleanup-marker-only job fails closed without --upload-only / fresh triplet verify, so the marker is not deleted and the failed job remains inspectable. Failed jobs still require an identity-bearing resume.

Issue relationship

None

Validation

git diff --check

deployment/aliyun/test-rust-lob-recovery-queue.sh — helpers reject empty and cleanup-marker-only spools, isolate queues complete undrained segments without queueing leftover cleanup markers, complete-only drain runs --upload-only without --recover-parts-only, and cleanup-marker-only drain fails without entering fresh-upload verify.

Runtime impact and rollback

Collector recovery only. After the next controller/runtime deploy of host-rust-lob-recovery-queue.sh, production ExecStartPre isolate will move pending complete segments into the recovery queue and will not isolate leftover cleanup markers. Rollback is the previous recovery controller. This is not a live trading change and does not auto-resume failed jobs.

Open in Web Open in Cursor 

@proerror77
proerror77 marked this pull request as ready for review September 12, 2026 04:45
@coderabbitai

coderabbitai Bot commented Sep 12, 2026

Copy link
Copy Markdown

Important

  • 🔍 Trigger review

This repository does not receive automatic reviews because it has fewer than 10 stars.

⚙️ Run configuration

Configuration used: defaults

Review profile: CHILL

Plan: Advanced

Run ID: 47ad3438-c6f9-48f4-967f-9d7c95c0efb2


Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

Comment @coderabbitai help to get the list of available commands.

@chatgpt-codex-connector

chatgpt-codex-connector Bot commented Sep 12, 2026

Copy link
Copy Markdown

Codex Review Summary

This comment shows the latest Codex review activity on this pull request.

Review Status Commit Review trigger
📝 Code Review Completed 2026-09-12T04:49:28.674719Z f28ccd8 Draft marked ready
ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

  • Open a pull request for review
  • Mark a draft as ready
  • Comment "@codex review" or "@codex security review".

Codex reacts with 👀 while any review is running, comments if it has suggestions, and reacts with 👍 once all reviews finish with no findings.

@chatgpt-codex-connector chatgpt-codex-connector Bot left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

💡 Codex Review

Here are some automated review suggestions for this pull request.

Reviewed commit: f28ccd8cba

ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

  • Open a pull request for review
  • Mark a draft as ready
  • Comment "@codex review".

If Codex has suggestions, it will comment; otherwise it will react with 👍.

Codex can also answer questions or update the PR. Try commenting "@codex address that feedback".

Comment thread deployment/aliyun/host-rust-lob-recovery-queue.sh Outdated
@cursor
cursor Bot force-pushed the cursor/collector-recovery-complete-segments-1729 branch from f28ccd8 to b803762 Compare September 12, 2026 05:08
cursoragent and others added 2 commits September 12, 2026 05:49
Recovery isolate previously skipped a spool with no incomplete parts, so
rotated complete manifests sat on the live spool after archiver death.
Isolate now queues those undrained complete segments; drain still uploads
them with --upload-only and does not invent a resume identity.

Co-authored-by: Wild Card <proerror77@users.noreply.github.com>
Do not isolate leftover uploaded-cleanup markers as undrained segments.
Drain refuses the fresh-upload verify path when only those markers remain,
so the marker is not deleted and the failed job stays inspectable.

Co-authored-by: Wild Card <proerror77@users.noreply.github.com>
@cursor
cursor Bot force-pushed the cursor/collector-recovery-complete-segments-1729 branch from b803762 to 3ef8c03 Compare September 12, 2026 05:49
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants