Skip to content

Commit

Permalink
Update asserted verifier error messages
Browse files Browse the repository at this point in the history
  • Loading branch information
driv3r committed Sep 11, 2024
1 parent e6eb592 commit c8e3c3f
Showing 1 changed file with 12 additions and 4 deletions.
16 changes: 12 additions & 4 deletions test/integration/interrupt_resume_test.rb
Original file line number Diff line number Diff line change
Expand Up @@ -254,8 +254,11 @@ def test_interrupt_resume_inline_verifier_will_verify_entries_in_reverify_store
assert_equal 1, incorrect_tables.length
assert_equal "gftest.test_table_1", incorrect_tables.first

error_line = ghostferry.error_lines.last
assert error_line["msg"].start_with?("cutover verification failed for: gftest.test_table_1 [paginationKeys: #{chosen_id}")
error_message = ghostferry.error_lines.last["msg"]
predicate = "cutover verification failed for: gftest.test_table_1 [PKs: #{chosen_id}"
expectation = error_message.start_with?(predicate)

assert expectation, "error message: #{error_message.inspect}, didn't start with #{predicate.inspect}"
end

def test_interrupt_resume_inline_verifier_will_verify_additional_rows_changed_on_source_during_interrupt
Expand Down Expand Up @@ -299,7 +302,7 @@ def test_interrupt_resume_inline_verifier_will_verify_additional_rows_changed_on
assert_equal "gftest.test_table_1", incorrect_tables.first

error_message = ghostferry.error_lines.last["msg"]
predicate = "cutover verification failed for: gftest.test_table_1 [paginationKeys: #{chosen_id}"
predicate = "cutover verification failed for: gftest.test_table_1 [PKs: #{chosen_id}"
expectation = error_message.start_with?(predicate)

assert expectation, "error message: #{error_message.inspect}, didn't start with #{predicate.inspect}"
Expand Down Expand Up @@ -669,6 +672,11 @@ def test_issue_149_corrupted

assert verification_ran
assert_equal ["#{DEFAULT_DB}.#{DEFAULT_TABLE}"], incorrect_tables
assert ghostferry.error_lines.last["msg"].start_with?("cutover verification failed for: gftest.test_table_1 [paginationKeys: #{id_to_change}")

error_message = ghostferry.error_lines.last["msg"]
predicate = "cutover verification failed for: gftest.test_table_1 [PKs: #{id_to_change}"
expectation = error_message.start_with?(predicate)

assert expectation, "error message: #{error_message.inspect}, didn't start with #{predicate.inspect}"
end
end

0 comments on commit c8e3c3f

Please sign in to comment.