tests

Author: ettec

go.mod

@@ -1,6 +1,6 @@
 module github.com/smartcontractkit/chainlink-common
 
-go 1.23.3
+go 1.23.4
 
 require (
 	github.com/XSAM/otelsql v0.29.0

pkg/workflows/wasm/host/wasm_test.go

@@ -191,7 +191,7 @@ func Test_Compute_Logs(t *testing.T) {
 		Fetch: func(ctx context.Context, req *wasmpb.FetchRequest) (*wasmpb.FetchResponse, error) {
 			return nil, nil
 		},
-	}, "", NewSingleBinaryWasmBinaryStore(binary))
+	}, "wf1", NewSingleBinaryWasmBinaryStore(binary))
 	require.NoError(t, err)
 
 	m.Start()
@@ -213,8 +213,21 @@ func Test_Compute_Logs(t *testing.T) {
 	_, err = m.Run(ctx, req)
 	assert.Nil(t, err)
 
-	require.Len(t, logs.AllUntimed(), 2)
+	require.Len(t, logs.AllUntimed(), 4)
 	expectedEntries := []Entry{
+		{
+			Log: zapcore.Entry{Level: zapcore.InfoLevel, Message: "loading module from binary"},
+			Fields: []zapcore.Field{
+				zap.String("workflowID", "wf1"),
+			},
+		},
+		{
+			Log: zapcore.Entry{Level: zapcore.InfoLevel, Message: "finished loading module from binary"},
+			Fields: []zapcore.Field{
+				zap.String("workflowID", "wf1"),
+			},
+		},
+
 		{
 			Log: zapcore.Entry{Level: zapcore.InfoLevel, Message: "building workflow..."},
 			Fields: []zapcore.Field{
@@ -550,9 +563,21 @@ func Test_Compute_Fetch(t *testing.T) {
 		_, err = m.Run(ctx, req)
 		assert.NotNil(t, err)
 		assert.ErrorContains(t, err, assert.AnError.Error())
-		require.Len(t, logs.AllUntimed(), 1)
+		require.Len(t, logs.AllUntimed(), 3)
 
 		expectedEntries := []Entry{
+			{
+				Log: zapcore.Entry{Level: zapcore.InfoLevel, Message: "loading module from binary"},
+				Fields: []zapcore.Field{
+					zap.String("workflowID", "wf1"),
+				},
+			},
+			{
+				Log: zapcore.Entry{Level: zapcore.InfoLevel, Message: "finished loading module from binary"},
+				Fields: []zapcore.Field{
+					zap.String("workflowID", "wf1"),
+				},
+			},
 			{
 				Log: zapcore.Entry{Level: zapcore.ErrorLevel, Message: fmt.Sprintf("error calling fetch: %s", assert.AnError)},
 			},