Skip to content

PIT Transforms

alphaforge.pit.transforms

PITTransformSpec dataclass

sanitized_params() -> dict[str, Any]

Params suitable for hashing and lineage serialization.

apply_binary_obs_path_transform(left_snapshot: pd.Series, right_snapshot: pd.Series, spec: PITTransformSpec) -> pd.Series

Apply a binary transform over two obs_date-indexed PIT snapshots.

apply_coalesce_obs_path_transform(snapshots: Mapping[str, pd.Series], spec: PITTransformSpec) -> pd.DataFrame

Apply a coalesce/splice transform over ordered PIT snapshots.

apply_obs_path_transform(snapshot: pd.Series, spec: PITTransformSpec, *, engine: RuntimeEngine = 'python') -> pd.Series

Apply a PIT transform over an obs_date-indexed snapshot path.

apply_revision_path_transform(timeline: pd.Series, spec: PITTransformSpec, *, engine: RuntimeEngine = 'python') -> pd.Series

Apply a PIT transform over an asof_utc-indexed revision timeline.

apply_splice_obs_path_transform(left_snapshot: pd.Series, right_snapshot: pd.Series, spec: PITTransformSpec) -> pd.DataFrame

Apply an adjusted PIT splice over two obs_date-indexed snapshots.