test(e2e): use the valid replay_on_change forward in microbatch lifecycle fixtures

Author: kvlonge

tests/e2e/src/sqlbuild/cli/commands/main/build/test_microbatch_direct_lifecycle.py

@@ -59,7 +59,7 @@ def test_given_serial_microbatch_when_building_then_state_table_is_not_used(
             "models/orders.sql": timestamp_microbatch_model_sql(
                 value_expression="payload",
                 batch_concurrency=1,
-                replay_policy="forward_only",
+                replay_policy="forward",
             ),
         },
     )
@@ -217,7 +217,7 @@ def test_given_concurrent_ceiling_when_first_run_and_full_refresh_then_target_bo
             "models/orders.sql": timestamp_microbatch_model_sql(
                 value_expression="payload",
                 batch_concurrency=3,
-                replay_policy="forward_only",
+                replay_policy="forward",
             ),
         },
     )
@@ -303,7 +303,7 @@ def test_given_recreated_target_when_building_then_old_completion_generation_is_
             "models/orders.sql": timestamp_microbatch_model_sql(
                 value_expression="payload",
                 batch_concurrency=2,
-                replay_policy="forward_only",
+                replay_policy="forward",
             ),
         },
     )

tests/e2e/src/sqlbuild/cli/commands/main/build/test_microbatch_failure_windows.py

@@ -59,7 +59,7 @@ def test_given_completion_write_failure_during_rebuild_when_retried_then_live_ta
             "models/orders.sql": timestamp_microbatch_model_sql(
                 value_expression="payload",
                 batch_concurrency=3,
-                replay_policy="forward_only",
+                replay_policy="forward",
             ),
             "adapters/failing_microbatch_state_duckdb.py": (
                 "import os\n"
@@ -166,7 +166,7 @@ def test_given_concurrent_delta_audit_failure_when_fixed_then_rejected_partition
             "models/orders.sql": timestamp_microbatch_model_sql(
                 value_expression="CAST(payload AS INTEGER)",
                 batch_concurrency=3,
-                replay_policy="forward_only",
+                replay_policy="forward",
                 extra_config=(
                     "audits [expression_is_true ("
                     'name "positive_value", expression "value > 0", severity error, '
@@ -255,7 +255,7 @@ def test_given_concurrent_batches_when_audit_and_hooks_wrap_model_then_aggregate
     model_sql: str = timestamp_microbatch_model_sql(
         value_expression="payload",
         batch_concurrency=3,
-        replay_policy="forward_only",
+        replay_policy="forward",
         extra_config=(
             "pre_hooks [inline_sql(\"INSERT INTO main.hook_log VALUES ('pre')\")], "
             "post_hooks [inline_sql(\"INSERT INTO main.hook_log VALUES ('post')\")],"

tests/e2e/src/sqlbuild/cli/commands/main/build/test_microbatch_replay_backfill_lifecycle.py

@@ -37,7 +37,7 @@ def test_given_ahead_of_frontier_partial_backfill_when_normal_run_resumes_then_l
         tmp_path=tmp_path,
         project_name="microbatch_future_backfill",
         database_name="future_backfill.duckdb",
-        replay_policy="forward_only",
+        replay_policy="forward",
     )
     execute_duckdb(
         db_path=db_path,
@@ -120,7 +120,7 @@ def test_given_failed_backfill_tail_when_source_tail_disappears_then_no_durable_
         tmp_path=tmp_path,
         project_name="microbatch_backfill_tail",
         database_name="backfill_tail.duckdb",
-        replay_policy="forward_only",
+        replay_policy="forward",
     )
     execute_duckdb(
         db_path=db_path,