Skip to content

Commit

Permalink
Fix
Browse files Browse the repository at this point in the history
  • Loading branch information
mateusz-sekara committed Oct 8, 2024
1 parent cee96f8 commit 243a751
Showing 1 changed file with 8 additions and 1 deletion.
9 changes: 8 additions & 1 deletion execute/tokendata/observer_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -420,6 +420,12 @@ func Test_CompositeTokenDataObserver_ParallelExecution(t *testing.T) {
usdcTokenSourcePool := internal.RandBytes().String()
randomTokenSourcePool := internal.RandBytes().String()

lggr := logger.Test(t)

t.Cleanup(func() {
_ = lggr.Sync()
})

tt := []struct {
name string
observers []tokendata.TokenDataObserver
Expand Down Expand Up @@ -549,14 +555,15 @@ func Test_CompositeTokenDataObserver_ParallelExecution(t *testing.T) {
defer cancel()
}

composite := tokendata.NewCompositeObservers(logger.Test(t), tc.observers...)
composite := tokendata.NewCompositeObservers(lggr, tc.observers...)

tkData, err := composite.Observe(ctx, tc.messageObservation)
require.NoError(t, err)

require.Equal(t, tc.expectedTokenData, tkData)
})
}

}

func faulty(prefix string, supportedTokens map[cciptypes.ChainSelector]string) *fakeObserver {
Expand Down

0 comments on commit 243a751

Please sign in to comment.