From ad566ba25b99d12fdf3edb790ab592e81f099555 Mon Sep 17 00:00:00 2001 From: Quigley Malcolm Date: Tue, 10 Dec 2024 09:24:54 -0600 Subject: [PATCH] Fix `TestMicrobatchMultipleRetries` and `TestMicrobatchSecondBatchFailure` tests --- tests/functional/microbatch/test_microbatch.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tests/functional/microbatch/test_microbatch.py b/tests/functional/microbatch/test_microbatch.py index 4769a202d8e..1d040c332ad 100644 --- a/tests/functional/microbatch/test_microbatch.py +++ b/tests/functional/microbatch/test_microbatch.py @@ -652,7 +652,7 @@ def models(self): def test_run_with_event_time(self, project): # run all partitions from start - 2 expected rows in output, one failed with patch_microbatch_end_time("2020-01-03 13:57:00"): - _, console_output = run_dbt_and_capture(["run"]) + _, console_output = run_dbt_and_capture(["run"], expect_pass=False) assert "PARTIAL SUCCESS (2/3)" in console_output assert "Completed with 1 partial success" in console_output @@ -751,7 +751,7 @@ def test_run_with_event_time(self, project): # run all partitions from start - 2 expected rows in output, one failed with patch_microbatch_end_time("2020-01-03 13:57:00"): - run_dbt(["run"], callbacks=[event_catcher.catch]) + run_dbt(["run"], expect_pass=False, callbacks=[event_catcher.catch]) assert len(event_catcher.caught_events) == 1 self.assert_row_count(project, "microbatch_model", 2)