From 64f7d7ad8b38bf48a2c33d58c7462c3870a29c8a Mon Sep 17 00:00:00 2001 From: Khalim Conn-Kowlessar Date: Mon, 6 Jul 2026 08:41:56 +0000 Subject: [PATCH] =?UTF-8?q?Thread=20the=20historic-EPC=20reader=20through?= =?UTF-8?q?=20the=20first-run=20composition=20root=20=F0=9F=9F=A9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Off by default like the other two prediction collaborators; the pipeline turns on Expired-Enhanced Prediction by passing a resolver over the historic S3 backup. Co-Authored-By: Claude Opus 4.8 --- applications/ara_first_run/handler.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/applications/ara_first_run/handler.py b/applications/ara_first_run/handler.py index acbbd74c7..704edd4e3 100644 --- a/applications/ara_first_run/handler.py +++ b/applications/ara_first_run/handler.py @@ -20,6 +20,7 @@ from orchestration.ara_first_run_pipeline import AraFirstRunPipeline from orchestration.ingestion_orchestrator import ( ComparablesRepo, EpcFetcher, + HistoricEpcReader, IngestionOrchestrator, PredictionAttributesReader, SolarFetcher, @@ -70,6 +71,7 @@ def build_first_run_pipeline( solar_fetcher: SolarFetcher, comparables_repo: Optional[ComparablesRepo] = None, prediction_attributes_reader: Optional[PredictionAttributesReader] = None, + historic_epc_reader: Optional[HistoricEpcReader] = None, ) -> AraFirstRunPipeline: """Compose the real three-stage pipeline on a Unit-of-Work factory. @@ -95,6 +97,9 @@ def build_first_run_pipeline( comparables_repo=comparables_repo, prediction_attributes_reader=prediction_attributes_reader, epc_prediction=EpcPrediction(), + # Expired-Enhanced Prediction (ADR-0054): off until a resolver over + # the historic S3 backup is supplied, like the two readers above. + historic_epc_reader=historic_epc_reader, ), baseline=PropertyBaselineOrchestrator( unit_of_work=unit_of_work,