Skip to content
This repository was archived by the owner on Jul 2, 2026. It is now read-only.

Commit a7440e5

Browse files
committed
Update package version
1 parent e14a26f commit a7440e5

7 files changed

Lines changed: 384 additions & 18 deletions

File tree

CHANGELOG.md

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,10 @@
1+
## [1.113.0] - 2026-05-12
2+
3+
### Added
4+
5+
- Add worker-scoped setup and validation context contracts for local H5 builds.
6+
7+
18
## [1.112.3] - 2026-05-12
29

310
### Fixed

changelog.d/951.added

Lines changed: 0 additions & 1 deletion
This file was deleted.

docs/engineering/pipeline-map.md

Lines changed: 50 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -753,7 +753,7 @@ Finalize release manifests, record run diagnostics paths, and clean staging stat
753753
### `modal_app.local_area.build_areas_worker`
754754

755755
```python
756-
def build_areas_worker(branch: str, run_id: str, work_items: List[Dict], calibration_inputs: Dict[str, str], validate: bool = True) -> Dict
756+
def build_areas_worker(branch: str, run_id: str, scope: str, work_items: List[Dict], calibration_inputs: WorkerCalibrationInputs | Mapping[str, object], validate: bool = True, scope_fingerprint: str | None = None) -> Dict
757757
```
758758

759759
Worker function that builds a subset of H5 files.
@@ -878,6 +878,14 @@ class AreaBuildRequest
878878

879879
Complete request for one local-area or national H5 file.
880880

881+
### `policyengine_us_data.build_outputs.validation.AreaValidationService`
882+
883+
```python
884+
class AreaValidationService
885+
```
886+
887+
Build validation state for all H5 requests handled by one worker.
888+
881889
### `policyengine_us_data.build_outputs.fingerprinting.ArtifactIdentity`
882890

883891
```python
@@ -966,6 +974,22 @@ class TraceabilityBundle
966974

967975
Full provenance record for one local H5 publish scope.
968976

977+
### `policyengine_us_data.build_outputs.validation.ValidationContext`
978+
979+
```python
980+
class ValidationContext
981+
```
982+
983+
Prepared validation data reused across all requests in one worker.
984+
985+
### `policyengine_us_data.build_outputs.validation.ValidationPolicy`
986+
987+
```python
988+
class ValidationPolicy
989+
```
990+
991+
Validation switch for a local H5 worker session.
992+
969993
### `policyengine_us_data.build_outputs.bootstrap.WorkerBootstrapBuilder`
970994

971995
```python
@@ -990,6 +1014,30 @@ class WorkerBootstrapStore
9901014

9911015
Filesystem adapter for scope-specific bootstrap bundle paths.
9921016

1017+
### `policyengine_us_data.build_outputs.worker_inputs.WorkerCalibrationInputs`
1018+
1019+
```python
1020+
class WorkerCalibrationInputs
1021+
```
1022+
1023+
Input artifact paths and runtime settings for one H5 worker batch.
1024+
1025+
### `policyengine_us_data.build_outputs.worker_session.WorkerSession`
1026+
1027+
```python
1028+
class WorkerSession
1029+
```
1030+
1031+
Prepared local H5 state for one worker process.
1032+
1033+
### `policyengine_us_data.build_outputs.worker_session.WorkerSessionFactory`
1034+
1035+
```python
1036+
class WorkerSessionFactory
1037+
```
1038+
1039+
Build worker-scoped setup from raw inputs or persisted bootstrap facts.
1040+
9931041
### `policyengine_us_data.calibration.promote_local_h5s.stage`
9941042

9951043
```python
@@ -1017,7 +1065,7 @@ Run unified calibration pipeline.
10171065
### `modal_app.local_area.run_phase`
10181066

10191067
```python
1020-
def run_phase(phase_name: str, work_items: List[Dict], num_workers: int, completed: set, branch: str, run_id: str, calibration_inputs: Dict[str, str], run_dir: Path, validate: bool = True) -> tuple
1068+
def run_phase(phase_name: str, work_items: List[Dict], num_workers: int, completed: set, branch: str, run_id: str, calibration_inputs: WorkerCalibrationInputs | Mapping[str, object], run_dir: Path, validate: bool = True, scope_fingerprint: str | None = None) -> tuple
10211069
```
10221070

10231071
Run a single build phase, spawning workers and collecting results.

0 commit comments

Comments
 (0)