Skip to content

ingest: port the vendor pipeline onto the current Lance stack - #758

Draft
SaveAanchal wants to merge 1 commit into
aanchal/mcap-lance-portfrom
aanchal/ingest-port
Draft

SaveAanchal wants to merge 1 commit into
aanchal/mcap-lance-portfrom
aanchal/ingest-port

Conversation

@SaveAanchal

Copy link
Copy Markdown
Contributor

Replaces #720: watcher, conversion job, staging, approval hand-off and commit round, using ingest's own staging root s3://rldb/lance_staging_mcap.

Tested: the full flow in unit tests against a stand-in store, with MANO off.
Not tested: real R2 ingest buckets or AWS Batch; the AWS GPU quota was 0 when last checked. Not ready for vendors.

🤖 Generated with Claude Code

Brings the #720 store, watcher, conversion jobs and AWS deploy over from
origin/aanchal/ingest, and connects them to the current committer:

- prepare() stages the delivery folder mcap_to_lance.write_delivery writes; the pin
  hashes those files.
- diff() finds a recording's steps table by (lab, embodiment, end_effector).
- Hand-off copies to <staging>/mcap-<lab>/<vendor id>/.
- commit_round only commits mcap-* sources, then annotation changes, so it can't act on
  another converter's folders.
- The default staging root is s3://rldb/lance_staging_mcap, apart from the migration's.

Also mutes ffmpeg while frames_in_message parses a packet: PyAV's batched log lines get
past av.logging.Capture.

Not run against real R2, Cloudflare or AWS Batch.

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
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.

1 participant