Consolidate staged batch artifacts into a pins board

Scans a staging directory for batch artifacts written by cs_run_batch(), validates the schema, and writes each batch into the pins board as a batch_{id} pin. Idempotent: if a batch pin already exists, it is skipped.

Usage

cs_consolidate(staging_dir, board)

Arguments

staging_dir

Directory containing staged RDS batch artifacts.

board

A pins board where batch pins should be written.

Value

Invisibly, the number of batches consolidated.