test_hero

The hero workflow: the predeclared pipeline over the goldens, and the avoided-materialization cost model.

Attributes

_STREAM

Functions

_run(**kwargs)
test_stages_match_the_individual_goldens() → None
test_the_pipeline_is_a_cardinality_funnel() → None
test_fusion_avoids_the_intermediate_materialization() → None
test_dma_bound_time_estimate_favours_fusion() → None
test_avoided_bytes_are_dominated_by_the_market_intermediate() → None
test_empty_after_alignment_still_prices() → None
test_fully_empty_workload_has_no_speedup_not_infinity() → None
test_roll_value_selects_the_windowed_bar_price() → None
test_int64_accumulator_roll_values_are_rejected() → None
test_window_below_two_is_rejected() → None
test_estimate_rejects_invalid_physical_parameters() → None
test_bucket_then_generic_aggregator_composes_to_time_bars() → None
test_hero_workflow_model_matches_the_function() → None

Module Contents

test_hero._STREAM

test_hero._run(**kwargs)

test_hero.test_stages_match_the_individual_goldens() → None

test_hero.test_the_pipeline_is_a_cardinality_funnel() → None

test_hero.test_fusion_avoids_the_intermediate_materialization() → None

test_hero.test_dma_bound_time_estimate_favours_fusion() → None

test_hero.test_avoided_bytes_are_dominated_by_the_market_intermediate() → None

test_hero.test_empty_after_alignment_still_prices() → None

test_hero.test_fully_empty_workload_has_no_speedup_not_infinity() → None

test_hero.test_roll_value_selects_the_windowed_bar_price() → None

test_hero.test_int64_accumulator_roll_values_are_rejected() → None

test_hero.test_window_below_two_is_rejected() → None

test_hero.test_estimate_rejects_invalid_physical_parameters() → None

test_hero.test_bucket_then_generic_aggregator_composes_to_time_bars() → None

test_hero.test_hero_workflow_model_matches_the_function() → None