numeraire_dataset.zones.wrds_equity.prepare_crsp_daily_equity#

numeraire_dataset.zones.wrds_equity.prepare_crsp_daily_equity(conn: _wrds.Connection, *, start_date: str | dt.date | pd.Timestamp, end_date: str | dt.date | pd.Timestamp, vintage: str | None = None, convention: DailyEquityConvention = 'siz', partitions: int = 64, home: str | Path | None = None, refresh: bool = False) DailyEquityCollection[source]#

Pull/cache one bucket at a time and publish its complete collection manifest.

A failed run leaves already-published immutable buckets available for a retry but publishes no collection manifest until every stock bucket and both calendar inputs are complete. Before any bucket query and again after all pulls, an immutable same-vintage CRSP release marker must agree with an immediate live marker; drift requires a new vintage. Frames are released before the next bucket, bounding client memory by one raw partition.