Lab 04: The Data Pipeline Wall

Lab 04: The Data Pipeline Wall · MLSysBook

import%20marimo%0A%0A__generated_with%20%3D%20%220.25.0%22%0Aapp%20%3D%20marimo.App(%0A%20%20%20%20width%3D%22full%22%2C%0A%20%20%20%20app_title%3D%22Lab%2004%3A%20The%20Data%20Pipeline%20Wall%20%C2%B7%20MLSysBook%22%2C%0A)%0A%0A%0A%40app.cell%0Aasync%20def%20_()%3A%0A%20%20%20%20import%20sys%0A%20%20%20%20from%20pathlib%20import%20Path%0A%20%20%20%20import%20marimo%20as%20mo%0A%0A%20%20%20%20if%20sys.platform%20%3D%3D%20%22emscripten%22%3A%0A%20%20%20%20%20%20%20%20import%20micropip%0A%20%20%20%20%20%20%20%20await%20micropip.install(%5B%22pydantic%22%2C%20%22pint%22%2C%20%22plotly%22%2C%20%22pandas%22%5D%2C%20keep_going%3DFalse)%0A%20%20%20%20%20%20%20%20await%20micropip.install(%22..%2F..%2Fwheels%2Fmlsysim-0.1.2-py3-none-any.whl%22%2C%20keep_going%3DFalse)%0A%20%20%20%20%20%20%20%20await%20micropip.install(%22..%2F..%2Fwheels%2Fmlsysbook_labs-0.1.0-py3-none-any.whl%22%2C%20keep_going%3DFalse)%0A%20%20%20%20else%3A%0A%20%20%20%20%20%20%20%20labs_dir%20%3D%20Path(__file__).resolve().parents%5B1%5D%0A%20%20%20%20%20%20%20%20if%20str(labs_dir)%20not%20in%20sys.path%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20sys.path.insert(0%2C%20str(labs_dir))%0A%20%20%20%20%20%20%20%20from%20bootstrap%20import%20native_bootstrap%0A%20%20%20%20%20%20%20%20native_bootstrap(__file__)%0A%0A%20%20%20%20import%20plotly.graph_objects%20as%20go%0A%20%20%20%20from%20mlsysim.core.units%20import%20Q_%0A%20%20%20%20from%20mlsysim.engine.v2_04_experiments%20import%20(%0A%20%20%20%20%20%20%20%20SCENARIO_ASSUMPTION%2C%20TIER_PLANS%2C%20evaluate_tier_plan%2C%0A%20%20%20%20%20%20%20%20evaluate_track_cache%2C%20evaluate_track_checkpoint%2C%20evaluate_track_demand%2C%0A%20%20%20%20%20%20%20%20evaluate_track_layout%2C%20make_miss_burst_trace%2C%20serialize_for_evidence%2C%0A%20%20%20%20%20%20%20%20simulate_cache_prefetch%2C%20track_profile%2C%0A%20%20%20%20)%0A%20%20%20%20from%20mlsysim.labs.state%20import%20DesignLedger%0A%20%20%20%20from%20mlsysim.labs.style%20import%20COLORS%2C%20LAB_CSS%2C%20apply_plotly_theme%0A%20%20%20%20from%20mlsysbook_labs%20import%20(%0A%20%20%20%20%20%20%20%20ACADEMIC_LAB_CSS%2C%20build_lab_report%2C%20get_lab_metadata%2C%20report_export_panel%2C%0A%20%20%20%20)%0A%20%20%20%20from%20mlsysbook_labs.experiment_evidence%20import%20audit_evidence%2C%20capture_evidence%0A%0A%20%20%20%20ledger%20%3D%20DesignLedger(volume%3D%22vol2%22)%0A%20%20%20%20if%20ledger.is_wasm%3A%0A%20%20%20%20%20%20%20%20_loaded%20%3D%20await%20ledger.load_async()%0A%20%20%20%20return%20(%0A%20%20%20%20%20%20%20%20ACADEMIC_LAB_CSS%2C%0A%20%20%20%20%20%20%20%20COLORS%2C%0A%20%20%20%20%20%20%20%20LAB_CSS%2C%0A%20%20%20%20%20%20%20%20Q_%2C%0A%20%20%20%20%20%20%20%20SCENARIO_ASSUMPTION%2C%0A%20%20%20%20%20%20%20%20TIER_PLANS%2C%0A%20%20%20%20%20%20%20%20apply_plotly_theme%2C%0A%20%20%20%20%20%20%20%20audit_evidence%2C%0A%20%20%20%20%20%20%20%20build_lab_report%2C%0A%20%20%20%20%20%20%20%20capture_evidence%2C%0A%20%20%20%20%20%20%20%20evaluate_tier_plan%2C%0A%20%20%20%20%20%20%20%20evaluate_track_cache%2C%0A%20%20%20%20%20%20%20%20evaluate_track_checkpoint%2C%0A%20%20%20%20%20%20%20%20evaluate_track_demand%2C%0A%20%20%20%20%20%20%20%20evaluate_track_layout%2C%0A%20%20%20%20%20%20%20%20get_lab_metadata%2C%0A%20%20%20%20%20%20%20%20go%2C%0A%20%20%20%20%20%20%20%20ledger%2C%0A%20%20%20%20%20%20%20%20mo%2C%0A%20%20%20%20%20%20%20%20report_export_panel%2C%0A%20%20%20%20%20%20%20%20serialize_for_evidence%2C%0A%20%20%20%20%20%20%20%20track_profile%2C%0A%20%20%20%20)%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20get_evidence%2C%20set_evidence%20%3D%20mo.state(%7B%7D)%0A%20%20%20%20return%20get_evidence%2C%20set_evidence%0A%0A%0A%40app.cell%0Adef%20_(mo%2C%20set_evidence)%3A%0A%20%20%20%20track%20%3D%20mo.ui.dropdown(%0A%20%20%20%20%20%20%20%20%7B%22TinyML%22%3A%20%22tinyml%22%2C%20%22Mobile%22%3A%20%22mobile%22%2C%20%22Edge%22%3A%20%22edge%22%2C%20%22Cloud%22%3A%20%22cloud%22%7D%2C%0A%20%20%20%20%20%20%20%20value%3D%22TinyML%22%2C%20label%3D%22Fleet%20track%22%2C%20on_change%3Dlambda%20_value%3A%20set_evidence(%7B%7D)%2C%0A%20%20%20%20)%0A%20%20%20%20return%20(track%2C)%0A%0A%0A%40app.cell%0Adef%20_(track%2C%20track_profile)%3A%0A%20%20%20%20track_id%20%3D%20track.value%0A%20%20%20%20profile%20%3D%20track_profile(track_id)%0A%20%20%20%20return%20profile%2C%20track_id%0A%0A%0A%40app.cell%0Adef%20_(mo%2C%20track_id)%3A%0A%20%20%20%20_track_key%20%3D%20track_id%0A%20%20%20%20a_scale%20%3D%20mo.ui.slider(1.2%2C%203.0%2C%20value%3D2.0%2C%20step%3D0.2%2C%20label%3D%22Active-consumer%20multiplier%22)%0A%20%20%20%20b_spacing%20%3D%20mo.ui.slider(1%2C%2010%2C%20value%3D2%2C%20step%3D1%2C%20label%3D%22Spacing%20inside%20miss%20burst%20(ms)%22)%0A%20%20%20%20b_prefetch%20%3D%20mo.ui.slider(0%2C%204%2C%20value%3D1%2C%20step%3D1%2C%20label%3D%22Prefetch%20lookahead%20(requests)%22)%0A%20%20%20%20c_shard%20%3D%20mo.ui.dropdown(%0A%20%20%20%20%20%20%20%20%7B%2264%20samples%22%3A%2064%2C%20%22256%20samples%22%3A%20256%2C%20%222%2C000%20samples%22%3A%202000%7D%2C%0A%20%20%20%20%20%20%20%20value%3D%2264%20samples%22%2C%20label%3D%22Samples%20per%20shard%22%2C%0A%20%20%20%20)%0A%20%20%20%20d_failure%20%3D%20mo.ui.dropdown(%0A%20%20%20%20%20%20%20%20%7B%22During%20local%20copy%22%3A%20%22local_copy%22%2C%20%22During%20durable%20publication%22%3A%20%22durable_publication%22%2C%20%22After%20durable%20publication%22%3A%20%22after_publication%22%7D%2C%0A%20%20%20%20%20%20%20%20value%3D%22After%20durable%20publication%22%2C%20label%3D%22Injected%20failure%22%2C%0A%20%20%20%20)%0A%20%20%20%20e_tested_tier%20%3D%20mo.ui.dropdown(%0A%20%20%20%20%20%20%20%20%7B%22Sharded%20regional%20tier%22%3A%20%22balanced%22%2C%20%22Performance%20tier%22%3A%20%22performance%22%7D%2C%0A%20%20%20%20%20%20%20%20value%3D%22Sharded%20regional%20tier%22%2C%20label%3D%22Tier%20to%20test%20against%20capacity-first%22%2C%0A%20%20%20%20)%0A%20%20%20%20e_decision%20%3D%20mo.ui.radio(%0A%20%20%20%20%20%20%20%20%7B%22Hold%20current%20placement%22%3A%20%22economy%22%2C%20%22Choose%20sharded%20regional%22%3A%20%22balanced%22%2C%20%22Choose%20performance%22%3A%20%22performance%22%2C%20%22No%20feasible%20design%22%3A%20%22no_feasible%22%7D%2C%0A%20%20%20%20%20%20%20%20label%3D%22Placement%20decision%22%2C%0A%20%20%20%20)%0A%20%20%20%20return%20(%0A%20%20%20%20%20%20%20%20a_scale%2C%0A%20%20%20%20%20%20%20%20b_prefetch%2C%0A%20%20%20%20%20%20%20%20b_spacing%2C%0A%20%20%20%20%20%20%20%20c_shard%2C%0A%20%20%20%20%20%20%20%20d_failure%2C%0A%20%20%20%20%20%20%20%20e_decision%2C%0A%20%20%20%20%20%20%20%20e_tested_tier%2C%0A%20%20%20%20)%0A%0A%0A%40app.cell%0Adef%20_(mo%2C%20track_id)%3A%0A%20%20%20%20_track_key%20%3D%20track_id%0A%20%20%20%20a_prediction%20%3D%20mo.ui.radio(%0A%20%20%20%20%20%20%20%20%7B%22No%20starvation%22%3A%20%22full%22%2C%20%2275%E2%80%9399%25%20utilization%22%3A%20%2275_99%22%2C%20%2250%E2%80%9374%25%20utilization%22%3A%20%2250_74%22%2C%20%22Below%2050%25%20utilization%22%3A%20%22below_50%22%7D%2C%0A%20%20%20%20%20%20%20%20label%3D%22After%20adding%20consumers%2C%20where%20will%20accelerator%20utilization%20land%3F%22%2C%0A%20%20%20%20).form(submit_button_label%3D%22Lock%20Part%20A%20prediction%22)%0A%20%20%20%20b_prediction%20%3D%20mo.ui.radio(%0A%20%20%20%20%20%20%20%20%7B%22Nearly%20unchanged%22%3A%20%22same%22%2C%20%22Burst%20stalls%20more%22%3A%20%22burst_more%22%2C%20%22Burst%20stalls%20less%22%3A%20%22burst_less%22%7D%2C%0A%20%20%20%20%20%20%20%20label%3D%22With%20the%20same%20objects%20and%20hit%20rate%2C%20what%20will%20correlated%20misses%20do%3F%22%2C%0A%20%20%20%20).form(submit_button_label%3D%22Lock%20Part%20B%20prediction%22)%0A%20%20%20%20c_prediction%20%3D%20mo.ui.radio(%0A%20%20%20%20%20%20%20%20%7B%22Storage%20bandwidth%22%3A%20%22storage%22%2C%20%22Metadata%20requests%22%3A%20%22metadata%22%2C%20%22Preprocessing%22%3A%20%22preprocess%22%7D%2C%0A%20%20%20%20%20%20%20%20label%3D%22Which%20stage%20binds%20for%20one-file-per-sample%20layout%3F%22%2C%0A%20%20%20%20).form(submit_button_label%3D%22Lock%20Part%20C%20prediction%22)%0A%20%20%20%20d_prediction%20%3D%20mo.ui.radio(%0A%20%20%20%20%20%20%20%20%7B%22Restorable%22%3A%20%22restorable%22%2C%20%22Not%20restorable%22%3A%20%22not_restorable%22%7D%2C%0A%20%20%20%20%20%20%20%20label%3D%22Will%20the%20selected%20failure%20leave%20this%20checkpoint%20restorable%3F%22%2C%0A%20%20%20%20).form(submit_button_label%3D%22Lock%20Part%20D%20prediction%22)%0A%20%20%20%20e_prediction%20%3D%20mo.ui.radio(%0A%20%20%20%20%20%20%20%20%7B%22Capacity-first%22%3A%20%22economy%22%2C%20%22Sharded%20regional%22%3A%20%22balanced%22%2C%20%22Performance%22%3A%20%22performance%22%7D%2C%0A%20%20%20%20%20%20%20%20label%3D%22Which%20placement%20has%20the%20lowest%20complete-job%20cost%3F%22%2C%0A%20%20%20%20).form(submit_button_label%3D%22Lock%20Part%20E%20prediction%22)%0A%20%20%20%20return%20a_prediction%2C%20b_prediction%2C%20c_prediction%2C%20d_prediction%2C%20e_prediction%0A%0A%0A%40app.cell%0Adef%20_(mo%2C%20track_id)%3A%0A%20%20%20%20_track_key%20%3D%20track_id%0A%20%20%20%20final_choice%20%3D%20mo.ui.radio(%0A%20%20%20%20%20%20%20%20%7B%22Hold%20current%20placement%22%3A%20%22economy%22%2C%20%22Choose%20sharded%20regional%22%3A%20%22balanced%22%2C%20%22Choose%20performance%22%3A%20%22performance%22%2C%20%22No%20feasible%20design%22%3A%20%22no_feasible%22%7D%2C%0A%20%20%20%20%20%20%20%20label%3D%22Final%20recommendation%22%2C%0A%20%20%20%20)%0A%20%20%20%20final_rejected%20%3D%20mo.ui.dropdown(%0A%20%20%20%20%20%20%20%20%7B%22Capacity-first%22%3A%20%22economy%22%2C%20%22Sharded%20regional%22%3A%20%22balanced%22%2C%20%22Performance%22%3A%20%22performance%22%7D%2C%0A%20%20%20%20%20%20%20%20value%3D%22Capacity-first%22%2C%20label%3D%22Quantified%20rejected%20alternative%22%2C%0A%20%20%20%20)%0A%20%20%20%20final_trigger%20%3D%20mo.ui.radio(%0A%20%20%20%20%20%20%20%20%7B%22Consumer%20count%20rises%2025%25%22%3A%20%22consumer_growth%22%2C%20%22Miss%20burst%20exceeds%20prefetch%20depth%22%3A%20%22miss_burst%22%2C%20%22Checkpoint%20deadline%20tightens%22%3A%20%22checkpoint_window%22%2C%20%22Storage%20prices%20change%2020%25%22%3A%20%22price_change%22%7D%2C%0A%20%20%20%20%20%20%20%20label%3D%22Reevaluation%20trigger%22%2C%0A%20%20%20%20)%0A%20%20%20%20final_risk%20%3D%20mo.ui.radio(%0A%20%20%20%20%20%20%20%20%7B%22Trace%20may%20miss%20rarer%20bursts%22%3A%20%22trace_coverage%22%2C%20%22Illustrative%20prices%20may%20drift%22%3A%20%22price_uncertainty%22%2C%20%22Restore%20was%20modeled%2C%20not%20exercised%22%3A%20%22restore_validation%22%7D%2C%0A%20%20%20%20%20%20%20%20label%3D%22Remaining%20limitation%22%2C%0A%20%20%20%20)%0A%20%20%20%20rationale%20%3D%20mo.ui.text_area(%0A%20%20%20%20%20%20%20%20label%3D%22Evidence-backed%20rationale%22%2C%0A%20%20%20%20%20%20%20%20placeholder%3D%22State%20the%20chosen%20tier%2C%20quantified%20rejected%20alternative%2C%20remaining%20limitation%2C%20and%20trigger.%22%2C%0A%20%20%20%20)%0A%20%20%20%20return%20final_choice%2C%20final_rejected%2C%20final_risk%2C%20final_trigger%2C%20rationale%0A%0A%0A%40app.cell%0Adef%20_(%0A%20%20%20%20Q_%2C%0A%20%20%20%20a_scale%2C%0A%20%20%20%20b_prefetch%2C%0A%20%20%20%20b_spacing%2C%0A%20%20%20%20c_shard%2C%0A%20%20%20%20d_failure%2C%0A%20%20%20%20e_tested_tier%2C%0A%20%20%20%20evaluate_tier_plan%2C%0A%20%20%20%20evaluate_track_cache%2C%0A%20%20%20%20evaluate_track_checkpoint%2C%0A%20%20%20%20evaluate_track_demand%2C%0A%20%20%20%20evaluate_track_layout%2C%0A%20%20%20%20track_id%2C%0A)%3A%0A%20%20%20%20a_base%20%3D%20evaluate_track_demand(track_id%2C%20consumer_scale%3D1.0)%0A%20%20%20%20a_result%20%3D%20evaluate_track_demand(track_id%2C%20consumer_scale%3Da_scale.value)%0A%20%20%20%20b_base%20%3D%20evaluate_track_cache(track_id%2C%20cold_spacing%3DQ_(25%2C%20%22millisecond%22)%2C%20prefetch_depth%3Db_prefetch.value)%0A%20%20%20%20b_result%20%3D%20evaluate_track_cache(track_id%2C%20cold_spacing%3DQ_(b_spacing.value%2C%20%22millisecond%22)%2C%20prefetch_depth%3Db_prefetch.value)%0A%20%20%20%20b_deeper%20%3D%20evaluate_track_cache(track_id%2C%20cold_spacing%3DQ_(b_spacing.value%2C%20%22millisecond%22)%2C%20prefetch_depth%3D4)%0A%20%20%20%20c_base%20%3D%20evaluate_track_layout(track_id%2C%20samples_per_object%3D1)%0A%20%20%20%20c_result%20%3D%20evaluate_track_layout(track_id%2C%20samples_per_object%3Dc_shard.value)%0A%20%20%20%20c_bandwidth%20%3D%20evaluate_track_layout(track_id%2C%20samples_per_object%3D1%2C%20storage_scale%3D2.0)%0A%20%20%20%20d_base%20%3D%20evaluate_track_checkpoint(track_id%2C%20failure_stage%3D%22durable_publication%22)%0A%20%20%20%20d_result%20%3D%20evaluate_track_checkpoint(track_id%2C%20failure_stage%3Dd_failure.value)%0A%20%20%20%20e_plans%20%3D%20%7Btier%3A%20evaluate_tier_plan(track_id%2C%20tier_id%3Dtier)%20for%20tier%20in%20(%22economy%22%2C%20%22balanced%22%2C%20%22performance%22)%7D%0A%20%20%20%20e_base%20%3D%20e_plans%5B%22economy%22%5D%0A%20%20%20%20e_result%20%3D%20e_plans%5Be_tested_tier.value%5D%0A%20%20%20%20return%20(%0A%20%20%20%20%20%20%20%20a_base%2C%0A%20%20%20%20%20%20%20%20a_result%2C%0A%20%20%20%20%20%20%20%20b_base%2C%0A%20%20%20%20%20%20%20%20b_deeper%2C%0A%20%20%20%20%20%20%20%20b_result%2C%0A%20%20%20%20%20%20%20%20c_bandwidth%2C%0A%20%20%20%20%20%20%20%20c_base%2C%0A%20%20%20%20%20%20%20%20c_result%2C%0A%20%20%20%20%20%20%20%20d_base%2C%0A%20%20%20%20%20%20%20%20d_result%2C%0A%20%20%20%20%20%20%20%20e_base%2C%0A%20%20%20%20%20%20%20%20e_plans%2C%0A%20%20%20%20%20%20%20%20e_result%2C%0A%20%20%20%20)%0A%0A%0A%40app.cell%0Adef%20_(%0A%20%20%20%20a_base%2C%0A%20%20%20%20a_prediction%2C%0A%20%20%20%20a_result%2C%0A%20%20%20%20b_base%2C%0A%20%20%20%20b_deeper%2C%0A%20%20%20%20b_prediction%2C%0A%20%20%20%20b_result%2C%0A%20%20%20%20c_bandwidth%2C%0A%20%20%20%20c_base%2C%0A%20%20%20%20c_prediction%2C%0A%20%20%20%20c_result%2C%0A%20%20%20%20capture_evidence%2C%0A%20%20%20%20d_base%2C%0A%20%20%20%20d_prediction%2C%0A%20%20%20%20d_result%2C%0A%20%20%20%20e_base%2C%0A%20%20%20%20e_decision%2C%0A%20%20%20%20e_plans%2C%0A%20%20%20%20e_prediction%2C%0A%20%20%20%20e_result%2C%0A%20%20%20%20mo%2C%0A%20%20%20%20serialize_for_evidence%2C%0A%20%20%20%20set_evidence%2C%0A%20%20%20%20track_id%2C%0A)%3A%0A%20%20%20%20def%20store(part%2C%20capture)%3A%0A%20%20%20%20%20%20%20%20set_evidence(lambda%20current%3A%20%7B**current%2C%20part%3A%20capture%7D)%0A%0A%20%20%20%20def%20frozen(value)%3A%0A%20%20%20%20%20%20%20%20return%20serialize_for_evidence(value)%0A%0A%20%20%20%20a_inputs%20%3D%20frozen(%7B%22baseline%22%3A%20a_base%5B%22inputs%22%5D%2C%20%22result%22%3A%20a_result%5B%22inputs%22%5D%7D)%0A%20%20%20%20b_inputs%20%3D%20frozen(%7B%22baseline%22%3A%20b_base%5B%22inputs%22%5D%2C%20%22result%22%3A%20b_result%5B%22inputs%22%5D%7D)%0A%20%20%20%20c_inputs%20%3D%20frozen(%7B%22baseline%22%3A%20c_base%5B%22inputs%22%5D%2C%20%22result%22%3A%20c_result%5B%22inputs%22%5D%7D)%0A%20%20%20%20d_inputs%20%3D%20frozen(%7B%22baseline%22%3A%20d_base%5B%22inputs%22%5D%2C%20%22result%22%3A%20d_result%5B%22inputs%22%5D%7D)%0A%20%20%20%20e_inputs%20%3D%20frozen(%7B%22baseline%22%3A%20e_base%5B%22inputs%22%5D%2C%20%22result%22%3A%20e_result%5B%22inputs%22%5D%2C%20%22decision%22%3A%20e_decision.value%7D)%0A%20%20%20%20_e_keeps_baseline%20%3D%20e_decision.value%20in%20%7B%22economy%22%2C%20%22no_feasible%22%7D%0A%20%20%20%20_e_mismatched_action%20%3D%20e_decision.value%20in%20%7B%22balanced%22%2C%20%22performance%22%7D%20and%20e_decision.value%20!%3D%20e_result%5B%22tier_id%22%5D%0A%20%20%20%20a_capture%20%3D%20mo.ui.button(%0A%20%20%20%20%20%20%20%20label%3D%22Capture%20demand%20boundary%22%2C%20kind%3D%22success%22%2C%20disabled%3Da_prediction.value%20is%20None%2C%0A%20%20%20%20%20%20%20%20on_click%3Dlambda%20_v%3A%20store(%22A%22%2C%20capture_evidence(track%3Dtrack_id%2C%20part%3D%22A%22%2C%20prediction%3Da_prediction.value%2C%20inputs%3Da_inputs%2C%20baseline%3Dfrozen(a_base)%2C%20result%3Dfrozen(a_result)%2C%20upstream_inputs%3Da_inputs%2C%20model_key%3D%22v2_04_experiments.evaluate_track_demand%22))%2C%0A%20%20%20%20)%0A%20%20%20%20b_capture%20%3D%20mo.ui.button(%0A%20%20%20%20%20%20%20%20label%3D%22Capture%20miss-trace%20contrast%22%2C%20kind%3D%22success%22%2C%20disabled%3Db_prediction.value%20is%20None%2C%0A%20%20%20%20%20%20%20%20on_click%3Dlambda%20_v%3A%20store(%22B%22%2C%20capture_evidence(track%3Dtrack_id%2C%20part%3D%22B%22%2C%20prediction%3Db_prediction.value%2C%20inputs%3Db_inputs%2C%20baseline%3Dfrozen(b_base)%2C%20result%3Dfrozen(b_result)%2C%20alternatives%3D(frozen(b_deeper)%2C)%2C%20upstream_inputs%3Db_inputs%2C%20model_key%3D%22v2_04_experiments.evaluate_track_cache%22))%2C%0A%20%20%20%20)%0A%20%20%20%20c_capture%20%3D%20mo.ui.button(%0A%20%20%20%20%20%20%20%20label%3D%22Capture%20layout%20decision%22%2C%20kind%3D%22success%22%2C%20disabled%3Dc_prediction.value%20is%20None%2C%0A%20%20%20%20%20%20%20%20on_click%3Dlambda%20_v%3A%20store(%22C%22%2C%20capture_evidence(track%3Dtrack_id%2C%20part%3D%22C%22%2C%20prediction%3Dc_prediction.value%2C%20inputs%3Dc_inputs%2C%20baseline%3Dfrozen(c_base)%2C%20result%3Dfrozen(c_result)%2C%20alternatives%3D(frozen(c_bandwidth)%2C)%2C%20upstream_inputs%3Dc_inputs%2C%20model_key%3D%22v2_04_experiments.evaluate_track_layout%22))%2C%0A%20%20%20%20)%0A%20%20%20%20d_capture%20%3D%20mo.ui.button(%0A%20%20%20%20%20%20%20%20label%3D%22Capture%20checkpoint%20failure%22%2C%20kind%3D%22success%22%2C%20disabled%3Dd_prediction.value%20is%20None%20or%20d_base%5B%22inputs%22%5D%20%3D%3D%20d_result%5B%22inputs%22%5D%2C%0A%20%20%20%20%20%20%20%20on_click%3Dlambda%20_v%3A%20store(%22D%22%2C%20capture_evidence(track%3Dtrack_id%2C%20part%3D%22D%22%2C%20prediction%3Dd_prediction.value%2C%20inputs%3Dd_inputs%2C%20baseline%3Dfrozen(d_base)%2C%20result%3Dfrozen(d_result)%2C%20upstream_inputs%3Dd_inputs%2C%20model_key%3D%22v2_04_experiments.evaluate_track_checkpoint%22))%2C%0A%20%20%20%20)%0A%20%20%20%20e_capture%20%3D%20mo.ui.button(%0A%20%20%20%20%20%20%20%20label%3D%22Capture%20placement%20decision%22%2C%20kind%3D%22success%22%2C%20disabled%3De_prediction.value%20is%20None%20or%20e_decision.value%20is%20None%20or%20_e_mismatched_action%2C%0A%20%20%20%20%20%20%20%20on_click%3Dlambda%20_v%3A%20store(%22E%22%2C%20capture_evidence(track%3Dtrack_id%2C%20part%3D%22E%22%2C%20prediction%3De_prediction.value%2C%20inputs%3De_inputs%2C%20baseline%3Dfrozen(e_base)%2C%20result%3Dfrozen(e_result)%2C%20chosen_result%3Dfrozen(e_base)%20if%20_e_keeps_baseline%20else%20None%2C%20result_role%3D%22rejected%20alternative%22%20if%20_e_keeps_baseline%20else%20%22tested%20intervention%22%2C%20alternatives%3Dtuple(frozen(e_plans%5Btier%5D)%20for%20tier%20in%20e_plans)%2C%20decision%3De_decision.value%2C%20upstream_inputs%3De_inputs%2C%20model_key%3D%22v2_04_experiments.evaluate_tier_plan%22))%2C%0A%20%20%20%20)%0A%20%20%20%20return%20(%0A%20%20%20%20%20%20%20%20a_capture%2C%0A%20%20%20%20%20%20%20%20a_inputs%2C%0A%20%20%20%20%20%20%20%20b_capture%2C%0A%20%20%20%20%20%20%20%20b_inputs%2C%0A%20%20%20%20%20%20%20%20c_capture%2C%0A%20%20%20%20%20%20%20%20c_inputs%2C%0A%20%20%20%20%20%20%20%20d_capture%2C%0A%20%20%20%20%20%20%20%20d_inputs%2C%0A%20%20%20%20%20%20%20%20e_capture%2C%0A%20%20%20%20%20%20%20%20e_inputs%2C%0A%20%20%20%20)%0A%0A%0A%40app.cell%0Adef%20_(ACADEMIC_LAB_CSS%2C%20LAB_CSS%2C%20SCENARIO_ASSUMPTION%2C%20mo%2C%20profile%2C%20track)%3A%0A%20%20%20%20css%20%3D%20mo.Html(%22%22%22%0A%20%20%20%20%3Cstyle%3E%0A%20%20%20%20.storage-head%7Bbackground%3Alinear-gradient(135deg%2C%23101827%2C%23164e63)%3Bcolor%3Awhite%3Bborder-radius%3A14px%3Bpadding%3Aclamp(18px%2C4vw%2C32px)%3Bmargin-bottom%3A12px%7D.storage-top%7Bdisplay%3Aflex%3Bjustify-content%3Aspace-between%3Bgap%3A8px%3Bflex-wrap%3Awrap%3Bfont%3A700%20.72rem%20ui-monospace%3Bletter-spacing%3A.08em%7D.storage-head%20h1%7Bfont-size%3Aclamp(1.65rem%2C5vw%2C2.65rem)%3Bline-height%3A1.05%3Bmargin%3A16px%200%208px%7D.storage-head%20p%7Bcolor%3A%23dbeafe%3Bmax-width%3A780px%7D.storage-meta%7Bdisplay%3Agrid%3Bgrid-template-columns%3Arepeat(auto-fit%2Cminmax(170px%2C1fr))%3Bgap%3A9px%3Bmargin-top%3A17px%7D.storage-meta%20div%7Bbackground%3A%23ffffff14%3Bborder%3A1px%20solid%20%23ffffff26%3Bpadding%3A9px%2011px%3Bborder-radius%3A8px%7D.track-row%7Bbackground%3A%23f8fafc%3Bborder%3A1px%20solid%20%23dbe3ec%3Bborder-radius%3A9px%3Bpadding%3A10px%2013px%7D.assumption%7Bcolor%3A%23475569%3Bfont-size%3A.88rem%3Bline-height%3A1.45%3Bmargin%3A0%7D.saved%7Bborder-left%3A4px%20solid%20%232ca02c%3Bbackground%3A%23f0fdf4%3Bpadding%3A9px%2012px%3Bborder-radius%3A7px%7D.lab-hud%7Bdisplay%3Aflex%3Balign-items%3Acenter%3Bflex-wrap%3Awrap%3Bgap%3A10px%3Bbackground%3A%23101827!important%3Bcolor%3A%23fff%3Bpadding%3A14px%2018px%3Bborder-radius%3A9px%7D.lab-hud%20.hud-label%7Bcolor%3A%23a7b9cf%7D.lab-hud%20.hud-value%7Bcolor%3A%23fff%7D.lab-hud%20.hud-active%7Bcolor%3A%2386efac%7D%40media(max-width%3A520px)%7B.storage-head%7Bborder-radius%3A9px%7D.storage-top%7Bpadding-left%3A30px%7D.storage-meta%7Bgrid-template-columns%3A1fr%7D.track-row%7Bpadding%3A9px%7D%7D%0A%20%20%20%20%3C%2Fstyle%3E%22%22%22)%0A%20%20%20%20header%20%3D%20mo.Html(f%22%22%22%3Csection%20class%3D%22storage-head%22%3E%3Cdiv%20class%3D%22storage-top%22%3E%3Cspan%3EVOLUME%20II%20%C2%B7%20LAB%2004%3C%2Fspan%3E%3Cspan%3EABOUT%2050%E2%80%9355%20MIN%3C%2Fspan%3E%3C%2Fdiv%3E%3Ch1%3EThe%20Data%20Pipeline%20Wall%3C%2Fh1%3E%3Cp%3EWhich%20complete%20storage%20path%20keeps%20a%20fleet%20productive%2C%20publishes%20restorable%20checkpoints%2C%20and%20earns%20its%20cost%3F%3C%2Fp%3E%3Cdiv%20class%3D%22storage-meta%22%3E%3Cdiv%3E%3Cb%3EFleet%20context%3C%2Fb%3E%3Cbr%3E%7Bprofile%5B'fleet_shape'%5D%7D%3C%2Fdiv%3E%3Cdiv%3E%3Cb%3EUnit%20of%20consumption%3C%2Fb%3E%3Cbr%3E%7Bprofile%5B'consumer_unit'%5D%7D%3C%2Fdiv%3E%3Cdiv%3E%3Cb%3EDeliverable%3C%2Fb%3E%3Cbr%3ETier-placement%20decision%20with%20saved%20evidence%3C%2Fdiv%3E%3C%2Fdiv%3E%3C%2Fsection%3E%22%22%22)%0A%20%20%20%20selector%20%3D%20mo.vstack(%5Bmo.md(%22**Choose%20a%20fleet%20track**%22)%2C%20track%5D).style(%7B%22max-width%22%3A%20%22420px%22%7D)%0A%20%20%20%20mo.vstack(%5BLAB_CSS%2C%20ACADEMIC_LAB_CSS%2C%20css%2C%20header%2C%20selector%2C%20mo.Html(f'%3Cp%20class%3D%22assumption%22%3E%7BSCENARIO_ASSUMPTION%7D%3C%2Fp%3E')%5D%2C%20gap%3D0.5).style(%7B%22padding-top%22%3A%20%2232px%22%7D)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.sidebar(%5Bmo.md(%22%23%23%20Lab%20navigation%22)%2C%20mo.outline(label%3D%22Sections%22)%5D)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(%0A%20%20%20%20COLORS%2C%0A%20%20%20%20TIER_PLANS%2C%0A%20%20%20%20a_base%2C%0A%20%20%20%20a_capture%2C%0A%20%20%20%20a_inputs%2C%0A%20%20%20%20a_prediction%2C%0A%20%20%20%20a_result%2C%0A%20%20%20%20a_scale%2C%0A%20%20%20%20apply_plotly_theme%2C%0A%20%20%20%20audit_evidence%2C%0A%20%20%20%20b_base%2C%0A%20%20%20%20b_capture%2C%0A%20%20%20%20b_deeper%2C%0A%20%20%20%20b_inputs%2C%0A%20%20%20%20b_prediction%2C%0A%20%20%20%20b_prefetch%2C%0A%20%20%20%20b_result%2C%0A%20%20%20%20b_spacing%2C%0A%20%20%20%20c_bandwidth%2C%0A%20%20%20%20c_base%2C%0A%20%20%20%20c_capture%2C%0A%20%20%20%20c_inputs%2C%0A%20%20%20%20c_prediction%2C%0A%20%20%20%20c_result%2C%0A%20%20%20%20c_shard%2C%0A%20%20%20%20d_base%2C%0A%20%20%20%20d_capture%2C%0A%20%20%20%20d_failure%2C%0A%20%20%20%20d_inputs%2C%0A%20%20%20%20d_prediction%2C%0A%20%20%20%20d_result%2C%0A%20%20%20%20e_base%2C%0A%20%20%20%20e_capture%2C%0A%20%20%20%20e_decision%2C%0A%20%20%20%20e_inputs%2C%0A%20%20%20%20e_plans%2C%0A%20%20%20%20e_prediction%2C%0A%20%20%20%20e_result%2C%0A%20%20%20%20e_tested_tier%2C%0A%20%20%20%20final_choice%2C%0A%20%20%20%20final_rejected%2C%0A%20%20%20%20final_risk%2C%0A%20%20%20%20final_trigger%2C%0A%20%20%20%20get_evidence%2C%0A%20%20%20%20go%2C%0A%20%20%20%20mo%2C%0A%20%20%20%20profile%2C%0A%20%20%20%20rationale%2C%0A%20%20%20%20track_id%2C%0A)%3A%0A%20%20%20%20_captures%20%3D%20get_evidence()%0A%20%20%20%20_upstream%20%3D%20%7B%22A%22%3A%20a_inputs%2C%20%22B%22%3A%20b_inputs%2C%20%22C%22%3A%20c_inputs%2C%20%22D%22%3A%20d_inputs%2C%20%22E%22%3A%20e_inputs%7D%0A%20%20%20%20audit%20%3D%20audit_evidence(_captures%2C%20track%3Dtrack_id%2C%20required_parts%3Dtuple(%22ABCDE%22)%2C%20per_part_upstream_inputs%3D_upstream%2C%20contrast_required_parts%3Dtuple(%22ABCDE%22))%0A%0A%20%20%20%20def%20qty(value%2C%20unit)%3A%0A%20%20%20%20%20%20%20%20return%20float(value.to(unit).magnitude)%0A%0A%20%20%20%20def%20table(rows)%3A%0A%20%20%20%20%20%20%20%20return%20mo.vstack(%5Bmo.ui.table(rows%2C%20pagination%3DFalse)%5D).style(%7B%22max-width%22%3A%20%22100%25%22%2C%20%22overflow-x%22%3A%20%22auto%22%7D)%0A%0A%20%20%20%20def%20saved(part)%3A%0A%20%20%20%20%20%20%20%20capture%20%3D%20_captures.get(part)%0A%20%20%20%20%20%20%20%20if%20capture%20is%20None%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20return%20mo.callout(mo.md(%22No%20saved%20evidence%20for%20this%20part.%22)%2C%20kind%3D%22warn%22)%0A%20%20%20%20%20%20%20%20if%20part%20in%20audit.stale%20or%20(part%2C%20part)%20in%20audit.identical_pairs%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20return%20mo.callout(mo.md(%22**STALE%20OR%20NON-CONTRASTING%20EVIDENCE.**%20Recapture%20after%20changing%20the%20live%20controls.%22)%2C%20kind%3D%22danger%22)%0A%20%20%20%20%20%20%20%20data%20%3D%20capture.to_dict()%0A%20%20%20%20%20%20%20%20return%20mo.Html(f'%3Cdiv%20class%3D%22saved%22%3E%3Cb%3ESaved%20snapshot%3C%2Fb%3E%20%C2%B7%20original%20prediction%3A%20%7Bdata%5B%22prediction%22%5D%7D%3Cbr%3E%3Csmall%3ETrack%20%7Bdata%5B%22track%22%5D%7D%3B%20later%20control%20changes%20do%20not%20rewrite%20this%20record.%3C%2Fsmall%3E%3C%2Fdiv%3E')%0A%0A%20%20%20%20def%20part_a()%3A%0A%20%20%20%20%20%20%20%20setup%20%3D%20mo.md(f%22%23%23%23%20A%20%C2%B7%20How%20many%20consumers%20can%20this%20path%20feed%3F%20(9%20min)%5CnThe%20**%7Bprofile%5B'consumer_unit'%5D%7D**%20consumes%20one%20local%20batch%20every%20**%7Bqty(profile%5B'step_time'%5D%2C%20'ms')%3A.0f%7D%20ms**.%20Predict%20the%20utilization%20boundary%20before%20increasing%20active%20fleet%20demand.%22)%0A%20%20%20%20%20%20%20%20if%20a_prediction.value%20is%20None%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20return%20mo.vstack(%5Bsetup%2C%20a_scale%2C%20a_prediction%5D)%0A%20%20%20%20%20%20%20%20figure%20%3D%20go.Figure()%0A%20%20%20%20%20%20%20%20figure.add_bar(name%3D%22Required%22%2C%20x%3D%5B%22Baseline%22%2C%20%22Added%20consumers%22%5D%2C%20y%3D%5Bqty(a_base%5B%22required_batches_per_second%22%5D%2C%20%22count%2Fs%22)%2C%20qty(a_result%5B%22required_batches_per_second%22%5D%2C%20%22count%2Fs%22)%5D%2C%20marker_color%3DCOLORS%5B%22OrangeLine%22%5D)%0A%20%20%20%20%20%20%20%20figure.add_bar(name%3D%22Delivered%22%2C%20x%3D%5B%22Baseline%22%2C%20%22Added%20consumers%22%5D%2C%20y%3D%5Bqty(a_base%5B%22delivered_batches_per_second%22%5D%2C%20%22count%2Fs%22)%2C%20qty(a_result%5B%22delivered_batches_per_second%22%5D%2C%20%22count%2Fs%22)%5D%2C%20marker_color%3DCOLORS%5B%22BlueLine%22%5D)%0A%20%20%20%20%20%20%20%20figure.update_layout(barmode%3D%22group%22%2C%20height%3D270%2C%20margin%3Ddict(l%3D20%2C%20r%3D20%2C%20t%3D20%2C%20b%3D20)%2C%20yaxis_title%3D%22Batches%2Fs%22)%0A%20%20%20%20%20%20%20%20rows%20%3D%20%5B%7B%22Run%22%3A%20label%2C%20%22Consumers%22%3A%20run%5B%22consumers%22%5D%2C%20%22Required%22%3A%20f%22%7Bqty(run%5B'required_bandwidth'%5D%2C%20'GB%2Fs')%3A.2f%7D%20GB%2Fs%22%2C%20%22Bottleneck%22%3A%20run%5B%22bottleneck%22%5D%2C%20%22Utilization%22%3A%20f%22%7Brun%5B'accelerator_utilization'%5D%3A.1%25%7D%22%7D%20for%20label%2C%20run%20in%20((%22Baseline%22%2C%20a_base)%2C%20(%22Added%22%2C%20a_result))%5D%0A%20%20%20%20%20%20%20%20return%20mo.vstack(%5Bsetup%2C%20a_scale%2C%20a_prediction%2C%20apply_plotly_theme(figure)%2C%20table(rows)%2C%20mo.callout(mo.md(f%22**Your%20prediction%3A**%20%7Ba_prediction.value%7D.%20The%20added-consumer%20run%20reaches%20**%7Ba_result%5B'accelerator_utilization'%5D%3A.1%25%7D%20utilization**%3B%20**%7Ba_result%5B'bottleneck'%5D%7D**%20limits%20delivery.%22)%2C%20kind%3D%22danger%22%20if%20a_result%5B%22starved%22%5D%20else%20%22success%22)%2C%20a_capture%2C%20saved(%22A%22)%2C%20mo.accordion(%7B%22Calculation%20Notes%22%3A%20mo.md(%22Required%20batch%20rate%20is%20active%20consumers%20%C3%97%20target%20utilization%20%C3%B7%20step%20time.%20Required%20byte%20rate%20multiplies%20by%20batch%20bytes.%20Storage%2C%20metadata%2C%20and%20preprocessing%20become%20batch%20service%20rates%3B%20their%20minimum%20limits%20delivery.%20Rates%20are%20illustrative%20assumptions.%22)%7D)%5D)%0A%0A%20%20%20%20def%20part_b()%3A%0A%20%20%20%20%20%20%20%20setup%20%3D%20mo.md(f%22%23%23%23%20B%20%C2%B7%20Why%20can%20a%20high%20hit%20rate%20still%20leave%20accelerators%20idle%3F%20(9%20min)%5CnThe%20**%7Bprofile%5B'consumer_unit'%5D%7D**%20consumes%20local%20batches%20from%20the%20storage%20tier%20(%7Bqty(profile%5B'storage_bandwidth'%5D%2C%20'GB%2Fs')%3A.1f%7D%20GB%2Fs%20profile%20bandwidth).%20Both%20traces%20request%20the%20same%20objects%20and%20bytes.%20Only%20the%20spacing%20of%20five%20cold%20misses%20changes.%20Commit%20before%20replaying%20them.%22)%0A%20%20%20%20%20%20%20%20if%20b_prediction.value%20is%20None%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20return%20mo.vstack(%5Bsetup%2C%20b_spacing%2C%20b_prefetch%2C%20b_prediction%5D)%0A%20%20%20%20%20%20%20%20labels%20%3D%20%5B%22Spread%20misses%22%2C%20%22Burst%20misses%22%2C%20%22Burst%20%2B%20depth%204%22%5D%0A%20%20%20%20%20%20%20%20runs%20%3D%20%5Bb_base%2C%20b_result%2C%20b_deeper%5D%0A%20%20%20%20%20%20%20%20figure%20%3D%20go.Figure(%5Bgo.Bar(x%3Dlabels%2C%20y%3D%5Bqty(run%5B%22total_stall%22%5D%2C%20%22ms%22)%20for%20run%20in%20runs%5D%2C%20marker_color%3D%5BCOLORS%5B%22BlueLine%22%5D%2C%20COLORS%5B%22OrangeLine%22%5D%2C%20COLORS%5B%22GreenLine%22%5D%5D)%5D)%0A%20%20%20%20%20%20%20%20figure.update_layout(height%3D270%2C%20margin%3Ddict(l%3D20%2C%20r%3D20%2C%20t%3D20%2C%20b%3D20)%2C%20yaxis_title%3D%22Total%20consumer%20stall%20(ms)%22%2C%20showlegend%3DFalse)%0A%20%20%20%20%20%20%20%20rows%20%3D%20%5B%7B%22Trace%22%3A%20label%2C%20%22Hit%20rate%22%3A%20f%22%7Brun%5B'hit_rate'%5D%3A.1%25%7D%22%2C%20%22Misses%22%3A%20run%5B%22cache_misses%22%5D%2C%20%22Max%20stall%22%3A%20f%22%7Bqty(run%5B'max_stall'%5D%2C%20'ms')%3A.1f%7D%20ms%22%7D%20for%20label%2C%20run%20in%20zip(labels%2C%20runs)%5D%0A%20%20%20%20%20%20%20%20return%20mo.vstack(%5Bsetup%2C%20mo.hstack(%5Bb_spacing%2C%20b_prefetch%5D%2C%20widths%3D%22equal%22%2C%20wrap%3DTrue)%2C%20b_prediction%2C%20apply_plotly_theme(figure)%2C%20table(rows)%2C%20mo.callout(mo.md(f%22**Your%20prediction%3A**%20%7Bb_prediction.value%7D.%20Hit%20rate%20remains%20**%7Bb_result%5B'hit_rate'%5D%3A.1%25%7D**%2C%20while%20correlated%20misses%20produce%20**%7Bqty(b_result%5B'total_stall'%5D%2C%20'ms')%3A.1f%7D%20ms**%20total%20stall.%20Lookahead%20changes%20readiness%2C%20not%20miss%20count.%22)%2C%20kind%3D%22info%22)%2C%20b_capture%2C%20saved(%22B%22)%2C%20mo.accordion(%7B%22Calculation%20Notes%22%3A%20mo.md(f%22The%20simulator%20replays%20timestamped%20batch%20requests%20for%20the%20%7Bprofile%5B'consumer_unit'%5D%7D%20through%20an%20LRU%20cache%20sized%20to%204%20batches%20(illustrative%20scenario%20assumption)%20using%20%7Bqty(profile%5B'storage_bandwidth'%5D%2C%20'GB%2Fs')%3A.1f%7D%20GB%2Fs%20storage%20bandwidth.%20Storage%20transfers%20serialize.%20A%20consumer%20stalls%20until%20its%20hit%20or%20transfer%20completes.%20This%20deterministic%20trace%20is%20an%20illustrative%20fixture%2C%20not%20a%20production%20measurement.%22)%7D)%5D)%0A%0A%20%20%20%20def%20part_c()%3A%0A%20%20%20%20%20%20%20%20setup%20%3D%20mo.md(%22%23%23%23%20C%20%C2%B7%20Should%20we%20buy%20bandwidth%20or%20change%20layout%3F%20(10%20min)%5CnThe%20same%20dataset%20can%20use%20one%20object%20per%20sample%20or%20packed%20shards.%20Predict%20the%20small-file%20bottleneck%20before%20viewing%20evidence.%22)%0A%20%20%20%20%20%20%20%20if%20c_prediction.value%20is%20None%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20return%20mo.vstack(%5Bsetup%2C%20c_prediction%5D)%0A%20%20%20%20%20%20%20%20labels%20%3D%20%5B%22Small%20files%22%2C%20%22Selected%20shards%22%2C%20%222%C3%97%20bandwidth%22%5D%0A%20%20%20%20%20%20%20%20runs%20%3D%20%5Bc_base%2C%20c_result%2C%20c_bandwidth%5D%0A%20%20%20%20%20%20%20%20figure%20%3D%20go.Figure(%5Bgo.Bar(x%3Dlabels%2C%20y%3D%5Bqty(run%5B%22elapsed%22%5D%2C%20%22s%22)%20for%20run%20in%20runs%5D%2C%20marker_color%3D%5BCOLORS%5B%22OrangeLine%22%5D%2C%20COLORS%5B%22GreenLine%22%5D%2C%20COLORS%5B%22BlueLine%22%5D%5D)%5D)%0A%20%20%20%20%20%20%20%20figure.update_layout(height%3D270%2C%20margin%3Ddict(l%3D20%2C%20r%3D20%2C%20t%3D20%2C%20b%3D20)%2C%20yaxis_title%3D%22Dataset%20pass%20time%20(s)%22%2C%20showlegend%3DFalse)%0A%20%20%20%20%20%20%20%20rows%20%3D%20%5B%7B%22Design%22%3A%20label%2C%20%22Requests%22%3A%20f%22%7Brun%5B'request_count'%5D%3A%2C%7D%22%2C%20%22Transferred%22%3A%20f%22%7Bqty(run%5B'transferred_bytes'%5D%2C%20'GB')%3A.3f%7D%20GB%22%2C%20%22Bottleneck%22%3A%20run%5B%22bottleneck%22%5D%7D%20for%20label%2C%20run%20in%20zip(labels%2C%20runs)%5D%0A%20%20%20%20%20%20%20%20return%20mo.vstack(%5Bsetup%2C%20c_prediction%2C%20c_shard%2C%20apply_plotly_theme(figure)%2C%20table(rows)%2C%20mo.callout(mo.md(f%22**Your%20prediction%3A**%20%7Bc_prediction.value%7D.%20Small%20files%20bind%20on%20**%7Bc_base%5B'bottleneck'%5D%7D**.%20Shards%20change%20request%20count%20and%20bytes%3B%20doubling%20bandwidth%20leaves%20small%20files%20bound%20on%20**%7Bc_bandwidth%5B'bottleneck'%5D%7D**.%22)%2C%20kind%3D%22info%22)%2C%20c_capture%2C%20saved(%22C%22)%2C%20mo.accordion(%7B%22Calculation%20Notes%22%3A%20mo.md(%22Request%20count%20is%20ceil(samples%20%C3%B7%20samples%20per%20object).%20Bytes%20include%20minimum-transfer%20padding%20and%20per-request%20overhead.%20Pass%20time%20is%20the%20maximum%20of%20transfer%2C%20metadata%2C%20and%20preprocessing%20time.%20Oversized%20final%20shards%20may%20move%20unused%20tail%20bytes.%22)%7D)%5D)%0A%0A%20%20%20%20def%20part_d()%3A%0A%20%20%20%20%20%20%20%20setup%20%3D%20mo.md(f%22%23%23%23%20D%20%C2%B7%20When%20is%20a%20checkpoint%20safely%20recoverable%3F%20(8%20min)%5CnCheckpoints%20belong%20to%20the%20**%7Bprofile%5B'consumer_unit'%5D%7D**%20in%20the%20regional%20backend%20training%20tier%20(%7Bprofile%5B'fleet_shape'%5D%7D)%3B%20TinyML%20and%20Mobile%20edge%20fleets%20stream%20data%20to%20the%20backend%20and%20never%20checkpoint%2048%20GB%20models%20locally%20on%20an%20MCU%20or%20phone.%20The%20checkpoint%20reaches%20local%20storage%2C%20then%20a%20durable%20tier%20publishes%20it.%20Choose%20a%20failure%20point%20and%20predict%20restore%20behavior.%22)%0A%20%20%20%20%20%20%20%20if%20d_prediction.value%20is%20None%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20return%20mo.vstack(%5Bsetup%2C%20d_failure%2C%20d_prediction%5D)%0A%20%20%20%20%20%20%20%20figure%20%3D%20go.Figure()%0A%20%20%20%20%20%20%20%20figure.add_bar(name%3D%22Local%20copy%22%2C%20y%3D%5B%22Checkpoint%22%5D%2C%20x%3D%5Bqty(d_result%5B%22local_duration%22%5D%2C%20%22s%22)%5D%2C%20orientation%3D%22h%22%2C%20marker_color%3DCOLORS%5B%22BlueLine%22%5D)%0A%20%20%20%20%20%20%20%20figure.add_bar(name%3D%22Durable%20publication%22%2C%20y%3D%5B%22Checkpoint%22%5D%2C%20x%3D%5Bqty(d_result%5B%22durable_duration%22%5D%2C%20%22s%22)%5D%2C%20orientation%3D%22h%22%2C%20marker_color%3DCOLORS%5B%22OrangeLine%22%5D)%0A%20%20%20%20%20%20%20%20figure.update_layout(barmode%3D%22stack%22%2C%20height%3D220%2C%20margin%3Ddict(l%3D20%2C%20r%3D20%2C%20t%3D20%2C%20b%3D20)%2C%20xaxis_title%3D%22Elapsed%20time%20(s)%22%2C%20legend_orientation%3D%22h%22)%0A%20%20%20%20%20%20%20%20outcome%20%3D%20%22RESTORABLE%22%20if%20d_result%5B%22recoverable%22%5D%20else%20%22NOT%20RESTORABLE%22%0A%20%20%20%20%20%20%20%20rows%20%3D%20%5B%7B%22Failure%22%3A%20d_result%5B%22failure_stage%22%5D.replace(%22_%22%2C%20%22%20%22)%2C%20%22Local%20complete%22%3A%20f%22%7Bqty(d_result%5B'local_complete'%5D%2C%20's')%3A.1f%7D%20s%22%2C%20%22Durable%20complete%22%3A%20f%22%7Bqty(d_result%5B'durable_complete'%5D%2C%20's')%3A.1f%7D%20s%22%2C%20%22Outcome%22%3A%20outcome%7D%5D%0A%20%20%20%20%20%20%20%20d_blocked%20%3D%20%5Bmo.callout(mo.md(%22Select%20an%20injected%20failure%20stage%20distinct%20from%20the%20baseline%20(durable%20publication)%20to%20produce%20a%20distinct%20contrast%20before%20capturing.%22)%2C%20kind%3D%22warn%22)%5D%20if%20d_base%5B%22inputs%22%5D%20%3D%3D%20d_result%5B%22inputs%22%5D%20else%20%5B%5D%0A%20%20%20%20%20%20%20%20return%20mo.vstack(%5Bsetup%2C%20d_failure%2C%20d_prediction%2C%20apply_plotly_theme(figure)%2C%20table(rows)%2C%20mo.callout(mo.md(f%22**Your%20prediction%3A**%20%7Bd_prediction.value%7D.%20**Analytical%20outcome%3A%20%7Boutcome%7D.**%20Local%20completion%20is%20staging%3B%20restore%20accepts%20the%20generation%20only%20after%20durable%20publication.%22)%2C%20kind%3D%22success%22%20if%20d_result%5B%22recoverable%22%5D%20else%20%22danger%22)%2C%20*d_blocked%2C%20d_capture%2C%20saved(%22D%22)%2C%20mo.accordion(%7B%22Calculation%20Notes%22%3A%20mo.md(f%22In%20TinyML%20and%20Mobile%20tracks%2C%20training%20checkpoints%20belong%20strictly%20to%20the%20regional%20backend%20training%20tier%20(%7Bprofile%5B'consumer_unit'%5D%7D)%2C%20never%20constrained%20MCU%20or%20mobile%20devices.%20Local%20completion%20%3D%20bytes%20%C3%B7%20local%20bandwidth.%20Durable%20publication%20adds%20bytes%20%C3%B7%20durable%20bandwidth.%20Failure%20strictly%20before%20durable%20completion%20exposes%20zero%20restorable%20bytes.%20Atomic%20manifest%20and%20checksum%20behavior%20are%20assumed.%22)%7D)%5D)%0A%0A%20%20%20%20def%20part_e()%3A%0A%20%20%20%20%20%20%20%20setup%20%3D%20mo.md(%22%23%23%23%20E%20%C2%B7%20Which%20tier%20placement%20earns%20its%20cost%3F%20(10%20min)%5CnCompare%20complete-job%20cost%20for%20a%20demanding%20fleet%20workload.%20Cost%20includes%20accelerator%20rental%20and%20its%20idle%20share%2C%20requests%2C%20movement%2C%20and%20retained%20capacity.%22)%0A%20%20%20%20%20%20%20%20if%20e_prediction.value%20is%20None%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20return%20mo.vstack(%5Bsetup%2C%20e_prediction%5D)%0A%20%20%20%20%20%20%20%20figure%20%3D%20go.Figure()%0A%20%20%20%20%20%20%20%20for%20tier%2C%20plan%20in%20e_plans.items()%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20figure.add_bar(name%3DTIER_PLANS%5Btier%5D%5B%22label%22%5D%2C%20x%3D%5B%22Accelerators%22%2C%20%22Requests%22%2C%20%22Movement%22%2C%20%22Capacity%22%5D%2C%20y%3D%5Bqty(plan%5B%22cost%22%5D%5B%22accelerator_cost%22%5D%2C%20%22dollar%22)%2C%20qty(plan%5B%22request_cost%22%5D%2C%20%22dollar%22)%2C%20qty(plan%5B%22movement_cost%22%5D%2C%20%22dollar%22)%2C%20qty(plan%5B%22capacity_cost%22%5D%2C%20%22dollar%22)%5D)%0A%20%20%20%20%20%20%20%20figure.update_layout(barmode%3D%22group%22%2C%20height%3D290%2C%20margin%3Ddict(l%3D20%2C%20r%3D20%2C%20t%3D20%2C%20b%3D20)%2C%20yaxis_title%3D%22Scenario%20cost%20(USD)%22%2C%20legend_orientation%3D%22h%22)%0A%20%20%20%20%20%20%20%20rows%20%3D%20%5B%7B%22Tier%22%3A%20plan%5B%22label%22%5D%2C%20%22Job%20time%22%3A%20f%22%7Bqty(plan%5B'job_duration'%5D%2C%20'hour')%3A.1f%7D%20h%22%2C%20%22Utilization%22%3A%20f%22%7Bplan%5B'accelerator_utilization'%5D%3A.1%25%7D%22%2C%20%22Idle%20accelerator%22%3A%20f%22%24%7Bqty(plan%5B'idle_accelerator_cost'%5D%2C%20'dollar')%3A%2C.0f%7D%22%2C%20%22Movement%22%3A%20f%22%24%7Bqty(plan%5B'movement_cost'%5D%2C%20'dollar')%3A%2C.2f%7D%22%2C%20%22Total%22%3A%20f%22%24%7Bqty(plan%5B'total_cost'%5D%2C%20'dollar')%3A%2C.0f%7D%22%7D%20for%20plan%20in%20e_plans.values()%5D%0A%20%20%20%20%20%20%20%20_e_mismatched%20%3D%20e_decision.value%20in%20%7B%22balanced%22%2C%20%22performance%22%7D%20and%20e_decision.value%20!%3D%20e_result%5B%22tier_id%22%5D%0A%20%20%20%20%20%20%20%20e_blocked%20%3D%20%5B%5D%0A%20%20%20%20%20%20%20%20if%20e_decision.value%20is%20None%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20e_blocked.append(mo.callout(mo.md(%22Select%20a%20placement%20decision%20to%20enable%20capture%20(deliberately%20holding%20current%20placement%20or%20concluding%20no%20feasible%20design%20is%20supported).%22)%2C%20kind%3D%22info%22))%0A%20%20%20%20%20%20%20%20elif%20_e_mismatched%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20e_blocked.append(mo.callout(mo.md(f%22To%20capture%2C%20make%20a%20consistent%20choice%3A%20test%20the%20tier%20you%20plan%20to%20adopt%20('%7Be_decision.value%7D')%2C%20or%20deliberately%20hold%20current%20placement%20%2F%20choose%20no%20feasible%20design.%22)%2C%20kind%3D%22warn%22))%0A%20%20%20%20%20%20%20%20return%20mo.vstack(%5Bsetup%2C%20e_prediction%2C%20e_tested_tier%2C%20apply_plotly_theme(figure)%2C%20table(rows)%2C%20e_decision%2C%20mo.callout(mo.md(f%22**Your%20prediction%3A**%20%7Be_prediction.value%7D.%20**%7Be_result%5B'label'%5D%7D**%20costs%20**%24%7Bqty(e_result%5B'total_cost'%5D%2C%20'dollar')%3A%2C.0f%7D**%20versus%20**%24%7Bqty(e_base%5B'total_cost'%5D%2C%20'dollar')%3A%2C.0f%7D**%20capacity-first.%20Higher%20movement%20price%20can%20reduce%20complete-job%20cost%20by%20avoiding%20idle%20hours.%22)%2C%20kind%3D%22info%22)%2C%20*e_blocked%2C%20e_capture%2C%20saved(%22E%22)%2C%20mo.accordion(%7B%22Calculation%20Notes%22%3A%20mo.md(%22Fixed%20useful-work%20duration%20is%20divided%20by%20delivered%20utilization%20for%20complete-job%20time.%20Accelerator%20rental%20is%20charged%20for%20that%20time%3B%20idle%20cost%20is%20its%20reported%20subset%2C%20not%20added%20twice.%20All%20prices%20are%20illustrative%20assumptions.%22)%7D)%5D)%0A%0A%20%20%20%20def%20build_synthesis()%3A%0A%20%20%20%20%20%20%20%20rows%20%3D%20%5B%5D%0A%20%20%20%20%20%20%20%20for%20part%20in%20%22ABCDE%22%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20capture%20%3D%20_captures.get(part)%0A%20%20%20%20%20%20%20%20%20%20%20%20status%20%3D%20%22MISSING%22%20if%20capture%20is%20None%20else%20(%22STALE%22%20if%20part%20in%20audit.stale%20or%20(part%2C%20part)%20in%20audit.identical_pairs%20else%20%22CURRENT%22)%0A%20%20%20%20%20%20%20%20%20%20%20%20rows.append(%7B%22Part%22%3A%20part%2C%20%22Original%20prediction%22%3A%20capture.to_dict()%5B%22prediction%22%5D%20if%20capture%20else%20%22%E2%80%94%22%2C%20%22Evidence%22%3A%20status%7D)%0A%20%20%20%20%20%20%20%20_saved_decision%20%3D%20_captures%5B%22E%22%5D.to_dict()%5B%22decision%22%5D%20if%20%22E%22%20in%20_captures%20else%20None%0A%20%20%20%20%20%20%20%20complete%20%3D%20audit.complete%20and%20all(widget.value%20is%20not%20None%20for%20widget%20in%20(final_choice%2C%20final_rejected%2C%20final_trigger%2C%20final_risk))%20and%20bool(rationale.value.strip())%20and%20final_choice.value%20%3D%3D%20_saved_decision%20and%20final_choice.value%20!%3D%20final_rejected.value%0A%20%20%20%20%20%20%20%20return%20mo.vstack(%5Bmo.md(%22%23%23%23%20Synthesis%20%C2%B7%20Defend%20one%20storage%20placement%20(5%20min)%5CnUse%20**demand%20%E2%86%92%20miss%20trace%20%E2%86%92%20layout%20%E2%86%92%20publication%20%E2%86%92%20cost**.%20Choose%20a%20placement%2C%20quantify%20a%20rejected%20alternative%2C%20name%20a%20limitation%2C%20and%20set%20a%20trigger.%22)%2C%20table(rows)%2C%20mo.callout(mo.md(%22Snapshots%20preserve%20original%20predictions%2C%20exact%20evaluator%20inputs%2C%20and%20results.%20Live%20changes%20mark%20evidence%20stale%3B%20they%20never%20rewrite%20history.%22)%2C%20kind%3D%22info%22)%2C%20mo.hstack(%5Bfinal_choice%2C%20final_rejected%5D%2C%20widths%3D%22equal%22%2C%20wrap%3DTrue)%2C%20mo.hstack(%5Bfinal_trigger%2C%20final_risk%5D%2C%20widths%3D%22equal%22%2C%20wrap%3DTrue)%2C%20rationale%2C%20mo.callout(mo.md(%22**Ready%20for%20the%20local%20report.**%22%20if%20complete%20else%20%22Capture%20five%20current%20contrasts%2C%20match%20the%20final%20recommendation%20to%20Part%20E%2C%20reject%20a%20different%20tier%2C%20and%20complete%20the%20rationale.%22)%2C%20kind%3D%22success%22%20if%20complete%20else%20%22warn%22)%5D)%0A%0A%20%20%20%20tabs%20%3D%20mo.ui.tabs(%7B%22Part%20A%22%3A%20part_a()%2C%20%22Part%20B%22%3A%20part_b()%2C%20%22Part%20C%22%3A%20part_c()%2C%20%22Part%20D%22%3A%20part_d()%2C%20%22Part%20E%22%3A%20part_e()%2C%20%22Synthesis%22%3A%20build_synthesis()%7D)%0A%20%20%20%20tabs%0A%20%20%20%20return%20(audit%2C)%0A%0A%0A%40app.cell%0Adef%20_(%0A%20%20%20%20audit%2C%0A%20%20%20%20build_lab_report%2C%0A%20%20%20%20final_choice%2C%0A%20%20%20%20final_rejected%2C%0A%20%20%20%20final_risk%2C%0A%20%20%20%20final_trigger%2C%0A%20%20%20%20get_evidence%2C%0A%20%20%20%20get_lab_metadata%2C%0A%20%20%20%20mo%2C%0A%20%20%20%20profile%2C%0A%20%20%20%20rationale%2C%0A%20%20%20%20report_export_panel%2C%0A%20%20%20%20track_id%2C%0A)%3A%0A%20%20%20%20_captures%20%3D%20get_evidence()%0A%20%20%20%20_saved_decision%20%3D%20_captures%5B%22E%22%5D.to_dict()%5B%22decision%22%5D%20if%20%22E%22%20in%20_captures%20else%20None%0A%20%20%20%20_ready%20%3D%20audit.complete%20and%20all(widget.value%20is%20not%20None%20for%20widget%20in%20(final_choice%2C%20final_rejected%2C%20final_trigger%2C%20final_risk))%20and%20bool(rationale.value.strip())%20and%20final_choice.value%20%3D%3D%20_saved_decision%20and%20final_choice.value%20!%3D%20final_rejected.value%0A%20%20%20%20mo.stop(not%20_ready)%0A%20%20%20%20snapshots%20%3D%20%7Bpart%3A%20_captures%5Bpart%5D.to_dict()%20for%20part%20in%20%22ABCDE%22%7D%0A%20%20%20%20_e_chosen%20%3D%20snapshots%5B%22E%22%5D.get(%22chosen_result%22)%20or%20snapshots%5B%22E%22%5D%5B%22result%22%5D%0A%20%20%20%20report%20%3D%20build_lab_report(%0A%20%20%20%20%20%20%20%20get_lab_metadata(%22vol2%2Flab_04_data_storage.py%22)%2C%20track%3Dtrack_id%2C%20scenario%3Dprofile%5B%22fleet_shape%22%5D%2C%0A%20%20%20%20%20%20%20%20learning_objectives%3D%5B%22Size%20a%20fleet%20data%20path%20from%20consumption%20and%20stage%20rates%22%2C%20%22Explain%20stalls%20with%20explicit%20misses%20and%20finite%20prefetch%22%2C%20%22Compare%20layout%2C%20publication%2C%20and%20lifecycle%20cost%22%5D%2C%0A%20%20%20%20%20%20%20%20predictions%3D%7Bpart%3A%20snapshots%5Bpart%5D%5B%22prediction%22%5D%20for%20part%20in%20%22ABCDE%22%7D%2C%20knob_settings%3D%7Bpart%3A%20snapshots%5Bpart%5D%5B%22inputs%22%5D%20for%20part%20in%20%22ABCDE%22%7D%2C%0A%20%20%20%20%20%20%20%20evidence_summary%3D%7Bpart%3A%20%7B%22baseline%22%3A%20snapshots%5Bpart%5D%5B%22baseline%22%5D%2C%20%22result%22%3A%20snapshots%5Bpart%5D%5B%22result%22%5D%2C%20%22chosen_result%22%3A%20snapshots%5Bpart%5D.get(%22chosen_result%22)%2C%20%22result_role%22%3A%20snapshots%5Bpart%5D.get(%22result_role%22)%2C%20%22alternatives%22%3A%20snapshots%5Bpart%5D%5B%22alternatives%22%5D%7D%20for%20part%20in%20%22ABCDE%22%7D%2C%0A%20%20%20%20%20%20%20%20binding_constraints%3D%7B%22A%22%3A%20snapshots%5B%22A%22%5D%5B%22result%22%5D%5B%22bottleneck%22%5D%2C%20%22B%22%3A%20f%22%7Bsnapshots%5B'B'%5D%5B'result'%5D%5B'cache_misses'%5D%7D%20traced%20misses%22%2C%20%22C%22%3A%20snapshots%5B%22C%22%5D%5B%22result%22%5D%5B%22bottleneck%22%5D%2C%20%22D%22%3A%20snapshots%5B%22D%22%5D%5B%22result%22%5D%5B%22failure_stage%22%5D%2C%20%22E%22%3A%20_e_chosen%5B%22bottleneck%22%5D%7D%2C%0A%20%20%20%20%20%20%20%20decisions%3D%7B%22recommendation%22%3A%20final_choice.value%2C%20%22rejected_alternative%22%3A%20final_rejected.value%2C%20%22reevaluation_trigger%22%3A%20final_trigger.value%7D%2C%0A%20%20%20%20%20%20%20%20final_decision%3D%7B%22recommendation%22%3A%20final_choice.value%2C%20%22rejected_alternative%22%3A%20final_rejected.value%2C%20%22rationale%22%3A%20rationale.value%7D%2C%0A%20%20%20%20%20%20%20%20big_takeaways%3D%5B%22The%20slowest%20complete-path%20service%20rate%20limits%20productivity.%22%2C%20%22Hit%20rate%20hides%20when%20correlated%20misses%20drain%20finite%20prefetch.%22%2C%20%22A%20checkpoint%20becomes%20restorable%20only%20after%20durable%20publication.%22%5D%2C%0A%20%20%20%20%20%20%20%20reflections%3D%7B%22rationale%22%3A%20rationale.value%2C%20%22reevaluation_trigger%22%3A%20final_trigger.value%7D%2C%20residual_risk%3Dfinal_risk.value%2C%0A%20%20%20%20%20%20%20%20result_snapshot%3D%7B%22track%22%3A%20track_id%2C%20%22captures%22%3A%20snapshots%2C%20%22recommendation%22%3A%20final_choice.value%2C%20%22rejected%22%3A%20final_rejected.value%2C%20%22trigger%22%3A%20final_trigger.value%2C%20%22residual_risk%22%3A%20final_risk.value%7D%2C%0A%20%20%20%20%20%20%20%20source_trace%3D%7B%22scenario%22%3A%20%22Illustrative%20fleet%20storage%20assumptions%3B%20analytical%20results%2C%20not%20measurements.%22%2C%20%22calculation_notes%22%3A%20%22Equations%20and%20uncertainty%20are%20stated%20in%20each%20saved%20part.%22%7D%2C%0A%20%20%20%20)%0A%20%20%20%20mo.vstack(%5Bmo.md(%22%23%23%20Local%20evidence%20report%22)%2C%20report_export_panel(report)%5D)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Aasync%20def%20_(%0A%20%20%20%20audit%2C%0A%20%20%20%20final_choice%2C%0A%20%20%20%20final_rejected%2C%0A%20%20%20%20final_risk%2C%0A%20%20%20%20final_trigger%2C%0A%20%20%20%20get_evidence%2C%0A%20%20%20%20ledger%2C%0A%20%20%20%20mo%2C%0A%20%20%20%20rationale%2C%0A%20%20%20%20track_id%2C%0A)%3A%0A%20%20%20%20_captures%20%3D%20get_evidence()%0A%20%20%20%20_saved_decision%20%3D%20_captures%5B%22E%22%5D.to_dict()%5B%22decision%22%5D%20if%20%22E%22%20in%20_captures%20else%20None%0A%20%20%20%20_ready%20%3D%20audit.complete%20and%20all(widget.value%20is%20not%20None%20for%20widget%20in%20(final_choice%2C%20final_rejected%2C%20final_trigger%2C%20final_risk))%20and%20bool(rationale.value.strip())%20and%20final_choice.value%20%3D%3D%20_saved_decision%20and%20final_choice.value%20!%3D%20final_rejected.value%0A%20%20%20%20_saved%20%3D%20False%0A%20%20%20%20_save_error%20%3D%20None%0A%20%20%20%20if%20_ready%3A%0A%20%20%20%20%20%20%20%20try%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20ledger.save(chapter%3D4%2C%20design%3D%7B%22schema_version%22%3A%201%2C%20%22lab_id%22%3A%20%22v2_04%22%2C%20%22track_id%22%3A%20track_id%2C%20%22model_id%22%3A%20%22v2_04_experiments%22%2C%20%22evidence%22%3A%20%7Bpart%3A%20capture.to_dict()%20for%20part%2C%20capture%20in%20get_evidence().items()%7D%2C%20%22recommendation%22%3A%20final_choice.value%2C%20%22rejected_alternative%22%3A%20final_rejected.value%2C%20%22reevaluation_trigger%22%3A%20final_trigger.value%2C%20%22residual_risk%22%3A%20final_risk.value%2C%20%22rationale%22%3A%20rationale.value%7D)%0A%20%20%20%20%20%20%20%20%20%20%20%20await%20ledger.flush()%0A%20%20%20%20%20%20%20%20%20%20%20%20_saved%20%3D%20True%0A%20%20%20%20%20%20%20%20except%20Exception%20as%20_error%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20_save_error%20%3D%20str(_error)%0A%20%20%20%20if%20_save_error%3A%0A%20%20%20%20%20%20%20%20_status%20%3D%20f%22SAVE%20FAILED%20%C2%B7%20%7B_save_error%7D%22%0A%20%20%20%20elif%20_saved%3A%0A%20%20%20%20%20%20%20%20_status%20%3D%20%22SAVED%22%0A%20%20%20%20else%3A%0A%20%20%20%20%20%20%20%20_status%20%3D%20%22EVIDENCE%20IN%20PROGRESS%22%0A%20%20%20%20mo.Html(f'%3Cdiv%20class%3D%22lab-hud%22%3E%3Cspan%20class%3D%22hud-label%22%3ELAB%3C%2Fspan%3E%3Cspan%20class%3D%22hud-value%22%3E04%20%C2%B7%20The%20Data%20Pipeline%20Wall%3C%2Fspan%3E%3Cspan%20style%3D%22flex%3A1%22%3E%3C%2Fspan%3E%3Cspan%20class%3D%22hud-label%22%3ESTATUS%3C%2Fspan%3E%3Cspan%20class%3D%22hud-active%22%3E%7B_status%7D%3C%2Fspan%3E%3C%2Fdiv%3E')%0A%20%20%20%20return%0A%0A%0Aif%20__name__%20%3D%3D%20%22__main__%22%3A%0A%20%20%20%20app.run()%0A