Skip to content

Commit

Permalink
Tests
Browse files Browse the repository at this point in the history
  • Loading branch information
nathan-artie committed Feb 9, 2024
1 parent 61e379c commit 3d1c36d
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions processes/consumer/process_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -103,9 +103,8 @@ func TestProcessMessageFailures(t *testing.T) {
assert.True(t, isOk)

tableName, err = processMessage(ctx, cfg, memDB, MockDestination{}, metrics.NullMetricsProvider{}, processArgs)
assert.True(t, strings.Contains(err.Error(),
fmt.Sprintf("err: format: %s is not supported", tcFmt.tc.CDCKeyFormat)), err.Error())
assert.True(t, strings.Contains(err.Error(), "cannot unmarshall key"), err.Error())
assert.ErrorContains(t, err, fmt.Sprintf("format: %s is not supported", tcFmt.tc.CDCKeyFormat), err.Error())
assert.ErrorContains(t, err, "cannot unmarshall key", err.Error())
assert.Equal(t, 0, len(memDB.TableData()))
assert.Empty(t, tableName)

Expand Down

0 comments on commit 3d1c36d

Please sign in to comment.