diff --git a/core/scripts/go.mod b/core/scripts/go.mod index bbdd50b4466..373b64be968 100644 --- a/core/scripts/go.mod +++ b/core/scripts/go.mod @@ -504,7 +504,7 @@ require ( github.com/smartcontractkit/chainlink-protos/rmn/v1.6/go v0.0.0-20250131130834-15e0d4cde2a6 // indirect github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0 // indirect github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3 // indirect - github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791 // indirect + github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f // indirect github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198 // indirect github.com/smartcontractkit/chainlink-solana/contracts v0.0.0-20260209164410-3aec83b0246f // indirect github.com/smartcontractkit/chainlink-sui v0.0.0-20260205175622-33e65031f9a9 // indirect diff --git a/core/scripts/go.sum b/core/scripts/go.sum index 3946e988552..46c153eb52e 100644 --- a/core/scripts/go.sum +++ b/core/scripts/go.sum @@ -1670,8 +1670,8 @@ github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0 h1:B7itmjy+C github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0/go.mod h1:h6kqaGajbNRrezm56zhx03p0mVmmA2xxj7E/M4ytLUA= github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3 h1:X8Pekpv+cy0eW1laZTwATuYLTLZ6gRTxz1ZWOMtU74o= github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3/go.mod h1:TcOliTQU6r59DwG4lo3U+mFM9WWyBHGuFkkxQpvSujo= -github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791 h1:S+yHuhcny3AKOhCekMQa65uUeR/p9rGrUIb8eifkSTY= -github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791/go.mod h1:GTpDgyK0OObf7jpch6p8N281KxN92wbB8serZhU9yRc= +github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f h1:3+vQMwuWL6+OqNutFqo/+gkczJwcr+MBPqeSxcjfI1Y= +github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f/go.mod h1:GTpDgyK0OObf7jpch6p8N281KxN92wbB8serZhU9yRc= github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198 h1:wWLBlbexHxP87lEdGR022Ve+2OW/MxvfWxg2U+uoMis= github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198/go.mod h1:/cw67XEnsP9wjQQH4BhL347Qy9HDg51+ETrMpdRTPIo= github.com/smartcontractkit/chainlink-solana/contracts v0.0.0-20260209164410-3aec83b0246f h1:XlAfD2E1/xrHRgMp8TwB8sdbbLZc+TzhGAeDDKqtLk0= diff --git a/core/services/workflows/engine.go b/core/services/workflows/engine.go index bb595ca8746..9dfb9f0f310 100644 --- a/core/services/workflows/engine.go +++ b/core/services/workflows/engine.go @@ -697,7 +697,7 @@ func (e *Engine) finishExecution(ctx context.Context, cma custmsg.MessageEmitter logCustMsg(ctx, cma, fmt.Sprintf("execution duration: %d (seconds)", executionDuration), l) l.Infof("execution duration: %d (seconds)", executionDuration) - err = events.EmitExecutionFinishedEvent(ctx, cma.Labels(), status, executionID, l) + err = events.EmitExecutionFinishedEvent(ctx, cma.Labels(), status, executionID, nil, l) if err != nil { e.logger.Errorf("failed to emit execution finished event: %+v", err) } diff --git a/core/services/workflows/events/emit.go b/core/services/workflows/events/emit.go index 8ad03183c00..e82d4df69ca 100644 --- a/core/services/workflows/events/emit.go +++ b/core/services/workflows/events/emit.go @@ -137,7 +137,7 @@ func EmitExecutionStartedEvent( return multiErr } -func EmitExecutionFinishedEvent(ctx context.Context, labels map[string]string, status string, executionID string, lggr logger.Logger) error { +func EmitExecutionFinishedEvent(ctx context.Context, labels map[string]string, status string, executionID string, execErr error, lggr logger.Logger) error { metadata := buildWorkflowMetadata(labels, executionID) event := &events.WorkflowExecutionFinished{ @@ -161,12 +161,18 @@ func EmitExecutionFinishedEvent(ctx context.Context, labels map[string]string, s executionStatus = eventsv2.ExecutionStatus_EXECUTION_STATUS_UNSPECIFIED } + var errMsg string + if execErr != nil { + errMsg = execErr.Error() + } + v2Event := &eventsv2.WorkflowExecutionFinished{ CreInfo: creInfo, Workflow: workflowKey, WorkflowExecutionID: executionID, Timestamp: time.Now().Format(time.RFC3339), Status: executionStatus, + Error: errMsg, } // Emit both v1 and v2 events diff --git a/core/services/workflows/events/emit_test.go b/core/services/workflows/events/emit_test.go index 883572ea748..4ec9c568ae1 100644 --- a/core/services/workflows/events/emit_test.go +++ b/core/services/workflows/events/emit_test.go @@ -1,6 +1,7 @@ package events_test import ( + "errors" "regexp" "testing" @@ -45,7 +46,7 @@ func TestEmit(t *testing.T) { }) t.Run(events.WorkflowExecutionFinished, func(t *testing.T) { - require.NoError(t, events.EmitExecutionFinishedEvent(t.Context(), labels, "status", executionID, nil)) + require.NoError(t, events.EmitExecutionFinishedEvent(t.Context(), labels, "status", executionID, nil, nil)) require.Len(t, labels, 1) msgs := beholderObserver.Messages(t, "beholder_entity", "workflows.v1."+events.WorkflowExecutionFinished) @@ -57,6 +58,20 @@ func TestEmit(t *testing.T) { assert.True(t, timeMatcher.MatchString(expected.Timestamp), expected.Timestamp) }) + t.Run(events.WorkflowExecutionFinished+"_with_error", func(t *testing.T) { + testErr := errors.New("something went wrong") + require.NoError(t, events.EmitExecutionFinishedEvent(t.Context(), labels, "errored", executionID, testErr, nil)) + + v2Msgs := beholderObserver.Messages(t, "beholder_entity", "workflows.v2."+events.WorkflowExecutionFinished) + require.NotEmpty(t, v2Msgs) + + // Check the latest v2 message contains the error + var v2Event eventsv2.WorkflowExecutionFinished + require.NoError(t, proto.Unmarshal(v2Msgs[len(v2Msgs)-1].Body, &v2Event)) + assert.Equal(t, "something went wrong", v2Event.Error) + assert.Equal(t, eventsv2.ExecutionStatus_EXECUTION_STATUS_FAILED, v2Event.Status) + }) + t.Run(events.CapabilityExecutionStarted, func(t *testing.T) { require.NoError(t, events.EmitCapabilityStartedEvent(t.Context(), labels, executionID, capabilityID, stepRef, "test-method")) require.Len(t, labels, 1) diff --git a/core/services/workflows/v2/engine.go b/core/services/workflows/v2/engine.go index 0b348c46ee9..40f32849ea3 100644 --- a/core/services/workflows/v2/engine.go +++ b/core/services/workflows/v2/engine.go @@ -668,6 +668,16 @@ func (e *Engine) startExecution(ctx context.Context, wrappedTriggerEvent enqueue _ = events.EmitExecutionStartedEvent(ctx, loggerLabels, triggerEvent.ID, executionID) e.metrics.With("workflowID", e.cfg.WorkflowID, "workflowName", e.cfg.WorkflowName.String()).IncrementWorkflowExecutionStartedCounter(ctx) + // Track execution error for deferred event emission + var execErr error + defer func() { + _ = events.EmitExecutionFinishedEvent(ctx, loggerLabels, executionStatus, executionID, execErr, lggr) + e.cfg.Hooks.OnExecutionFinished(executionID, executionStatus) + if execErr != nil { + e.cfg.Hooks.OnExecutionError(execErr.Error()) + } + }() + var timeProvider TimeProvider = &types.LocalTimeProvider{} if !e.cfg.UseLocalTimeProvider { timeProvider = NewDonTimeProvider(e.cfg.DonTimeStore, e.cfg.WorkflowID, lggr) @@ -676,10 +686,14 @@ func (e *Engine) startExecution(ctx context.Context, wrappedTriggerEvent enqueue moduleExecuteMaxResponseSizeBytes, err := e.cfg.LocalLimiters.ExecutionResponse.Limit(ctx) if err != nil { lggr.Errorw("Failed to get execution response size limit", "err", err) + executionStatus = store.StatusErrored + execErr = err return } if moduleExecuteMaxResponseSizeBytes < 0 { - lggr.Errorf("invalid moduleExecuteMaxResponseSizeBytes; must not be negative: %d", moduleExecuteMaxResponseSizeBytes) + execErr = fmt.Errorf("invalid moduleExecuteMaxResponseSizeBytes; must not be negative: %d", moduleExecuteMaxResponseSizeBytes) + lggr.Errorw(execErr.Error()) + executionStatus = store.StatusErrored return } execHelper := &ExecutionHelper{ @@ -687,7 +701,8 @@ func (e *Engine) startExecution(ctx context.Context, wrappedTriggerEvent enqueue TimeProvider: timeProvider, SecretsFetcher: e.secretsFetcher(executionID), } execHelper.initLimiters(e.cfg.LocalLimiters) - result, execErr := e.cfg.Module.Execute(execCtx, &sdkpb.ExecuteRequest{ + var result *sdkpb.ExecutionResult + result, execErr = e.cfg.Module.Execute(execCtx, &sdkpb.ExecuteRequest{ Request: &sdkpb.ExecuteRequest_Trigger{ Trigger: &sdkpb.Trigger{ Id: tid, @@ -730,11 +745,7 @@ func (e *Engine) startExecution(ctx context.Context, wrappedTriggerEvent enqueue } else { e.metrics.UpdateWorkflowErrorDurationHistogram(ctx, int64(executionDuration.Seconds())) } - executionLogger.Errorw("Workflow execution failed with module execution error", "status", executionStatus, "durationMs", executionDuration.Milliseconds(), "err", execErr) - _ = events.EmitExecutionFinishedEvent(ctx, loggerLabels, executionStatus, executionID, lggr) - e.cfg.Hooks.OnExecutionFinished(executionID, executionStatus) - e.cfg.Hooks.OnExecutionError(execErr.Error()) return } @@ -744,22 +755,18 @@ func (e *Engine) startExecution(ctx context.Context, wrappedTriggerEvent enqueue if len(result.GetError()) > 0 { executionStatus = store.StatusErrored + execErr = errors.New(result.GetError()) e.metrics.UpdateWorkflowErrorDurationHistogram(ctx, int64(executionDuration.Seconds())) e.metrics.With("workflowID", e.cfg.WorkflowID, "workflowName", e.cfg.WorkflowName.String()).IncrementWorkflowExecutionFailedCounter(ctx) executionLogger.Errorw("Workflow execution failed", "status", executionStatus, "durationMs", executionDuration.Milliseconds(), "error", result.GetError()) - _ = events.EmitExecutionFinishedEvent(ctx, loggerLabels, executionStatus, executionID, lggr) - e.cfg.Hooks.OnExecutionFinished(executionID, executionStatus) - e.cfg.Hooks.OnExecutionError(result.GetError()) return } executionStatus = store.StatusCompleted executionLogger.Infow("Workflow execution finished successfully", "durationMs", executionDuration.Milliseconds()) - _ = events.EmitExecutionFinishedEvent(ctx, loggerLabels, executionStatus, executionID, lggr) e.metrics.UpdateWorkflowCompletedDurationHistogram(ctx, int64(executionDuration.Seconds())) e.metrics.With("workflowID", e.cfg.WorkflowID, "workflowName", e.cfg.WorkflowName.String()).IncrementWorkflowExecutionSucceededCounter(ctx) e.cfg.Hooks.OnResultReceived(result) - e.cfg.Hooks.OnExecutionFinished(executionID, executionStatus) } func (e *Engine) secretsFetcher(phaseID string) SecretsFetcher { diff --git a/deployment/go.mod b/deployment/go.mod index 40dae1b7224..76d3755c5dc 100644 --- a/deployment/go.mod +++ b/deployment/go.mod @@ -440,7 +440,7 @@ require ( github.com/smartcontractkit/chainlink-protos/rmn/v1.6/go v0.0.0-20250131130834-15e0d4cde2a6 // indirect github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0 // indirect github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3 // indirect - github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791 // indirect + github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f // indirect github.com/smartcontractkit/chainlink-testing-framework/parrot v0.6.2 // indirect github.com/smartcontractkit/chainlink-testing-framework/seth v1.51.3 // indirect github.com/smartcontractkit/chainlink-tron/relayer v0.0.11-0.20251014143056-a0c6328c91e9 // indirect diff --git a/deployment/go.sum b/deployment/go.sum index db209ef485e..8188ac85b54 100644 --- a/deployment/go.sum +++ b/deployment/go.sum @@ -1427,8 +1427,8 @@ github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0 h1:B7itmjy+C github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0/go.mod h1:h6kqaGajbNRrezm56zhx03p0mVmmA2xxj7E/M4ytLUA= github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3 h1:X8Pekpv+cy0eW1laZTwATuYLTLZ6gRTxz1ZWOMtU74o= github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3/go.mod h1:TcOliTQU6r59DwG4lo3U+mFM9WWyBHGuFkkxQpvSujo= -github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791 h1:S+yHuhcny3AKOhCekMQa65uUeR/p9rGrUIb8eifkSTY= -github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791/go.mod h1:GTpDgyK0OObf7jpch6p8N281KxN92wbB8serZhU9yRc= +github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f h1:3+vQMwuWL6+OqNutFqo/+gkczJwcr+MBPqeSxcjfI1Y= +github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f/go.mod h1:GTpDgyK0OObf7jpch6p8N281KxN92wbB8serZhU9yRc= github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198 h1:wWLBlbexHxP87lEdGR022Ve+2OW/MxvfWxg2U+uoMis= github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198/go.mod h1:/cw67XEnsP9wjQQH4BhL347Qy9HDg51+ETrMpdRTPIo= github.com/smartcontractkit/chainlink-solana/contracts v0.0.0-20260209164410-3aec83b0246f h1:XlAfD2E1/xrHRgMp8TwB8sdbbLZc+TzhGAeDDKqtLk0= diff --git a/go.mod b/go.mod index 8cf5e10388c..ff2b6a7826e 100644 --- a/go.mod +++ b/go.mod @@ -105,7 +105,7 @@ require ( github.com/smartcontractkit/chainlink-protos/orchestrator v0.10.0 github.com/smartcontractkit/chainlink-protos/ring/go v0.0.0-20260128151123-605e9540b706 github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0 - github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791 + github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198 github.com/smartcontractkit/chainlink-sui v0.0.0-20260124000807-bff5e296dfb7 github.com/smartcontractkit/chainlink-ton v0.0.0-20260211155338-cd4708d2b938 diff --git a/go.sum b/go.sum index ba7be21eef1..36b4639a09e 100644 --- a/go.sum +++ b/go.sum @@ -1235,8 +1235,8 @@ github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0 h1:B7itmjy+C github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0/go.mod h1:h6kqaGajbNRrezm56zhx03p0mVmmA2xxj7E/M4ytLUA= github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3 h1:X8Pekpv+cy0eW1laZTwATuYLTLZ6gRTxz1ZWOMtU74o= github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3/go.mod h1:TcOliTQU6r59DwG4lo3U+mFM9WWyBHGuFkkxQpvSujo= -github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791 h1:S+yHuhcny3AKOhCekMQa65uUeR/p9rGrUIb8eifkSTY= -github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791/go.mod h1:GTpDgyK0OObf7jpch6p8N281KxN92wbB8serZhU9yRc= +github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f h1:3+vQMwuWL6+OqNutFqo/+gkczJwcr+MBPqeSxcjfI1Y= +github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f/go.mod h1:GTpDgyK0OObf7jpch6p8N281KxN92wbB8serZhU9yRc= github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198 h1:wWLBlbexHxP87lEdGR022Ve+2OW/MxvfWxg2U+uoMis= github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198/go.mod h1:/cw67XEnsP9wjQQH4BhL347Qy9HDg51+ETrMpdRTPIo= github.com/smartcontractkit/chainlink-sui v0.0.0-20260124000807-bff5e296dfb7 h1:06HM7tgzZW24XrJEMFcB6U+HwvmGfKU8u2jrI1wrFeI= diff --git a/integration-tests/go.mod b/integration-tests/go.mod index 96ec0579d27..8389fbe02c5 100644 --- a/integration-tests/go.mod +++ b/integration-tests/go.mod @@ -524,7 +524,7 @@ require ( github.com/smartcontractkit/chainlink-protos/rmn/v1.6/go v0.0.0-20250131130834-15e0d4cde2a6 // indirect github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0 // indirect github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3 // indirect - github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791 // indirect + github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f // indirect github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198 // indirect github.com/smartcontractkit/chainlink-testing-framework/framework v0.13.14-0.20260202230832-eb33f42188d1 // indirect github.com/smartcontractkit/chainlink-tron/relayer v0.0.11-0.20251014143056-a0c6328c91e9 // indirect diff --git a/integration-tests/go.sum b/integration-tests/go.sum index 394b5140303..a5c39327ef7 100644 --- a/integration-tests/go.sum +++ b/integration-tests/go.sum @@ -1671,8 +1671,8 @@ github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0 h1:B7itmjy+C github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0/go.mod h1:h6kqaGajbNRrezm56zhx03p0mVmmA2xxj7E/M4ytLUA= github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3 h1:X8Pekpv+cy0eW1laZTwATuYLTLZ6gRTxz1ZWOMtU74o= github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3/go.mod h1:TcOliTQU6r59DwG4lo3U+mFM9WWyBHGuFkkxQpvSujo= -github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791 h1:S+yHuhcny3AKOhCekMQa65uUeR/p9rGrUIb8eifkSTY= -github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791/go.mod h1:GTpDgyK0OObf7jpch6p8N281KxN92wbB8serZhU9yRc= +github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f h1:3+vQMwuWL6+OqNutFqo/+gkczJwcr+MBPqeSxcjfI1Y= +github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f/go.mod h1:GTpDgyK0OObf7jpch6p8N281KxN92wbB8serZhU9yRc= github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198 h1:wWLBlbexHxP87lEdGR022Ve+2OW/MxvfWxg2U+uoMis= github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198/go.mod h1:/cw67XEnsP9wjQQH4BhL347Qy9HDg51+ETrMpdRTPIo= github.com/smartcontractkit/chainlink-sui v0.0.0-20260205175622-33e65031f9a9 h1:KyPROV+v7P8VdiU7JhVuGLcDlEBsURSpQmSCgNBTY+s= diff --git a/integration-tests/load/go.mod b/integration-tests/load/go.mod index 8d64290eb3b..1d6dcf4fb9d 100644 --- a/integration-tests/load/go.mod +++ b/integration-tests/load/go.mod @@ -510,7 +510,7 @@ require ( github.com/smartcontractkit/chainlink-protos/rmn/v1.6/go v0.0.0-20250131130834-15e0d4cde2a6 // indirect github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0 // indirect github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3 // indirect - github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791 // indirect + github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f // indirect github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198 // indirect github.com/smartcontractkit/chainlink-sui v0.0.0-20260205175622-33e65031f9a9 // indirect github.com/smartcontractkit/chainlink-sui/deployment v0.0.0-20260124000807-bff5e296dfb7 // indirect diff --git a/integration-tests/load/go.sum b/integration-tests/load/go.sum index b272e381c90..7ed6411c29f 100644 --- a/integration-tests/load/go.sum +++ b/integration-tests/load/go.sum @@ -1649,8 +1649,8 @@ github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0 h1:B7itmjy+C github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0/go.mod h1:h6kqaGajbNRrezm56zhx03p0mVmmA2xxj7E/M4ytLUA= github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3 h1:X8Pekpv+cy0eW1laZTwATuYLTLZ6gRTxz1ZWOMtU74o= github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3/go.mod h1:TcOliTQU6r59DwG4lo3U+mFM9WWyBHGuFkkxQpvSujo= -github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791 h1:S+yHuhcny3AKOhCekMQa65uUeR/p9rGrUIb8eifkSTY= -github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791/go.mod h1:GTpDgyK0OObf7jpch6p8N281KxN92wbB8serZhU9yRc= +github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f h1:3+vQMwuWL6+OqNutFqo/+gkczJwcr+MBPqeSxcjfI1Y= +github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f/go.mod h1:GTpDgyK0OObf7jpch6p8N281KxN92wbB8serZhU9yRc= github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198 h1:wWLBlbexHxP87lEdGR022Ve+2OW/MxvfWxg2U+uoMis= github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198/go.mod h1:/cw67XEnsP9wjQQH4BhL347Qy9HDg51+ETrMpdRTPIo= github.com/smartcontractkit/chainlink-sui v0.0.0-20260205175622-33e65031f9a9 h1:KyPROV+v7P8VdiU7JhVuGLcDlEBsURSpQmSCgNBTY+s= diff --git a/system-tests/lib/go.mod b/system-tests/lib/go.mod index 24d39792b25..fa65617b1ad 100644 --- a/system-tests/lib/go.mod +++ b/system-tests/lib/go.mod @@ -39,7 +39,7 @@ require ( github.com/smartcontractkit/chainlink-evm/gethwrappers v0.0.0-20251222115927-36a18321243c github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260210221717-2546aed27ebe github.com/smartcontractkit/chainlink-protos/job-distributor v0.17.0 - github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791 + github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198 github.com/smartcontractkit/chainlink-testing-framework/framework v0.13.14-0.20260202230832-eb33f42188d1 github.com/smartcontractkit/chainlink-testing-framework/framework/components/dockercompose v0.1.15 diff --git a/system-tests/lib/go.sum b/system-tests/lib/go.sum index 2ad59d37ecd..d01aad1efaf 100644 --- a/system-tests/lib/go.sum +++ b/system-tests/lib/go.sum @@ -1626,8 +1626,8 @@ github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0 h1:B7itmjy+C github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0/go.mod h1:h6kqaGajbNRrezm56zhx03p0mVmmA2xxj7E/M4ytLUA= github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3 h1:X8Pekpv+cy0eW1laZTwATuYLTLZ6gRTxz1ZWOMtU74o= github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3/go.mod h1:TcOliTQU6r59DwG4lo3U+mFM9WWyBHGuFkkxQpvSujo= -github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791 h1:S+yHuhcny3AKOhCekMQa65uUeR/p9rGrUIb8eifkSTY= -github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791/go.mod h1:GTpDgyK0OObf7jpch6p8N281KxN92wbB8serZhU9yRc= +github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f h1:3+vQMwuWL6+OqNutFqo/+gkczJwcr+MBPqeSxcjfI1Y= +github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f/go.mod h1:GTpDgyK0OObf7jpch6p8N281KxN92wbB8serZhU9yRc= github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198 h1:wWLBlbexHxP87lEdGR022Ve+2OW/MxvfWxg2U+uoMis= github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198/go.mod h1:/cw67XEnsP9wjQQH4BhL347Qy9HDg51+ETrMpdRTPIo= github.com/smartcontractkit/chainlink-solana/contracts v0.0.0-20260209164410-3aec83b0246f h1:XlAfD2E1/xrHRgMp8TwB8sdbbLZc+TzhGAeDDKqtLk0= diff --git a/system-tests/tests/go.mod b/system-tests/tests/go.mod index 0a4274e948a..545d901a5ba 100644 --- a/system-tests/tests/go.mod +++ b/system-tests/tests/go.mod @@ -62,7 +62,7 @@ require ( github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260210221717-2546aed27ebe github.com/smartcontractkit/chainlink-protos/job-distributor v0.17.0 github.com/smartcontractkit/chainlink-protos/ring/go v0.0.0-20260128151123-605e9540b706 - github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791 + github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f github.com/smartcontractkit/chainlink-testing-framework/framework v0.13.14-0.20260202230832-eb33f42188d1 github.com/smartcontractkit/chainlink-testing-framework/framework/components/fake v0.10.0 github.com/smartcontractkit/chainlink-testing-framework/havoc v1.50.7 diff --git a/system-tests/tests/go.sum b/system-tests/tests/go.sum index dfb8eecd618..7ec17151fce 100644 --- a/system-tests/tests/go.sum +++ b/system-tests/tests/go.sum @@ -1835,8 +1835,8 @@ github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0 h1:B7itmjy+C github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0/go.mod h1:h6kqaGajbNRrezm56zhx03p0mVmmA2xxj7E/M4ytLUA= github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3 h1:X8Pekpv+cy0eW1laZTwATuYLTLZ6gRTxz1ZWOMtU74o= github.com/smartcontractkit/chainlink-protos/svr v1.1.1-0.20260203131522-bb8bc5c423b3/go.mod h1:TcOliTQU6r59DwG4lo3U+mFM9WWyBHGuFkkxQpvSujo= -github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791 h1:S+yHuhcny3AKOhCekMQa65uUeR/p9rGrUIb8eifkSTY= -github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260205231316-3b9c600dd791/go.mod h1:GTpDgyK0OObf7jpch6p8N281KxN92wbB8serZhU9yRc= +github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f h1:3+vQMwuWL6+OqNutFqo/+gkczJwcr+MBPqeSxcjfI1Y= +github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260217043601-5cc966896c4f/go.mod h1:GTpDgyK0OObf7jpch6p8N281KxN92wbB8serZhU9yRc= github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198 h1:wWLBlbexHxP87lEdGR022Ve+2OW/MxvfWxg2U+uoMis= github.com/smartcontractkit/chainlink-solana v1.1.2-0.20260211115641-f96bb4343198/go.mod h1:/cw67XEnsP9wjQQH4BhL347Qy9HDg51+ETrMpdRTPIo= github.com/smartcontractkit/chainlink-solana/contracts v0.0.0-20260209164410-3aec83b0246f h1:XlAfD2E1/xrHRgMp8TwB8sdbbLZc+TzhGAeDDKqtLk0=