Re-enable e2e log trigger test using beholder logs (#20307)

* hopeful attempt using beholder logs

* stop this for now

* stop this as well

* just pause everything for now

* silence regression

* Revert and remove flake, pending removal of read cap for logtrigger test

* stop sending tx on log trigger

* tidy

* final stuff

* final stuff

Author: yashnevatia

system-tests/tests/go.mod

@@ -72,7 +72,6 @@ require (
 	github.com/smartcontractkit/chainlink/system-tests/tests/smoke/cre/evm/logtrigger v0.0.0-00010101000000-000000000000
 	github.com/smartcontractkit/chainlink/system-tests/tests/smoke/cre/evmread v0.0.0-20250917232237-c4ecf802c6f8
 	github.com/smartcontractkit/libocr v0.0.0-20251031190958-7324c200a6b0
-	github.com/smartcontractkit/quarantine v0.0.0-20250909213106-ece491bef618
 	github.com/stretchr/testify v1.11.1
 	golang.org/x/sync v0.17.0
 	google.golang.org/protobuf v1.36.10

system-tests/tests/smoke/cre/cre_suite_test.go

@@ -6,8 +6,6 @@ import (
 
 	"github.com/stretchr/testify/require"
 
-	"github.com/smartcontractkit/quarantine"
-
 	"github.com/smartcontractkit/chainlink/system-tests/lib/cre/environment/blockchains"
 	t_helpers "github.com/smartcontractkit/chainlink/system-tests/tests/test-helpers"
 )
@@ -162,7 +160,6 @@ func Test_CRE_V2_EVM_Suite(t *testing.T) {
 	})
 
 	t.Run("[v2] EVM LogTrigger - "+topology, func(t *testing.T) {
-		quarantine.Flaky(t, "PLEX-1894")
 		ExecuteEVMLogTriggerTest(t, testEnv)
 	})
 }

system-tests/tests/smoke/cre/evm/logtrigger/go.mod

@@ -4,7 +4,6 @@ go 1.24.5
 
 require (
 	github.com/ethereum/go-ethereum v1.16.3
-	github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20250911124514-5874cc6d62b2
 	github.com/smartcontractkit/cre-sdk-go v0.8.0
 	github.com/smartcontractkit/cre-sdk-go/capabilities/blockchain/evm v0.8.0
 	github.com/stretchr/testify v1.11.1
@@ -18,6 +17,7 @@ require (
 	github.com/holiman/uint256 v1.3.2 // indirect
 	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
 	github.com/shopspring/decimal v1.4.0 // indirect
+	github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20250911124514-5874cc6d62b2 // indirect
 	golang.org/x/crypto v0.36.0 // indirect
 	golang.org/x/sys v0.34.0 // indirect
 	google.golang.org/protobuf v1.36.8 // indirect

system-tests/tests/smoke/cre/evm/logtrigger/main.go

@@ -9,8 +9,6 @@ import (
 	"strings"
 
 	"github.com/ethereum/go-ethereum/accounts/abi"
-	"github.com/ethereum/go-ethereum/common"
-	sdkpb "github.com/smartcontractkit/chainlink-protos/cre/go/sdk"
 	"github.com/smartcontractkit/cre-sdk-go/capabilities/blockchain/evm"
 	"github.com/smartcontractkit/cre-sdk-go/cre"
 	"github.com/smartcontractkit/cre-sdk-go/cre/wasm"
@@ -104,32 +102,9 @@ func onTrigger(cfg logtrigger.Config, runtime sdk.Runtime, outputs *evm.Log) (st
 		return "", fmt.Errorf("OnTrigger error decoding log data: %w", err)
 	}
 	runtime.Logger().Info(fmt.Sprintf("OnTrigger decoded message: %s", decodedMessageString))
-	client := evm.Client{ChainSelector: cfg.ChainSelector}
-	txHash := sendTx(t, runtime, cfg, client, decodedMessageString)
-	runtime.Logger().Info("Successfully sent transaction", "hash", common.Hash(txHash).String())
 	return "success", nil
 }
 
-func sendTx(t *T, runtime sdk.Runtime, cfg logtrigger.Config, client evm.Client, msg string) []byte {
-	// NOTE: This is not a right way to send a transaction. Msg must be properly encoded to trigger a proper receiver contract call.
-	// In this case we just need to see transaction on chain, so it's sufficient.
-	report, err := runtime.GenerateReport(&sdkpb.ReportRequest{
-		EncodedPayload: []byte(msg),
-		EncoderName:    "evm",
-		SigningAlgo:    "ecdsa",
-		HashingAlgo:    "keccak256",
-	}).Await()
-	require.NoError(t, err, "failed to generate report")
-	reportReply, err := client.WriteReport(runtime, &evm.WriteCreReportRequest{
-		Receiver:  common.HexToAddress(cfg.Addresses[0]).Bytes(),
-		Report:    report,
-		GasConfig: &evm.GasConfig{GasLimit: 500_000},
-	}).Await()
-	require.NoError(t, err, "failed to write report")
-	require.NotNil(t, reportReply)
-	return reportReply.TxHash
-}
-
 func printDecodedData(t *T, runtime sdk.Runtime, eventABI string, eventName string, data []byte) (string, error) {
 	require.NotNil(t, eventABI, "eventABI input should not be nil")
 	require.NotNil(t, eventName, "eventName input should not be nil")

system-tests/tests/smoke/cre/v2_evm_capability_test.go

@@ -233,17 +233,23 @@ func ExecuteEVMLogTriggerTest(t *testing.T, testEnv *ttypes.TestEnvironment) {
 	for chainID, bcOutput := range chainsToTest {
 		lggr.Info().Msgf("Creating EVM LogTrigger workflow configuration for chain %s", chainID)
 		workflowConfig, msgEmitter := configureEVMLogTriggerWorkflow(t, lggr, bcOutput)
-
+		listenerCtx, messageChan, kafkaErrChan := t_helpers.StartBeholder(t, lggr, testEnv)
 		workflowName := fmt.Sprintf("evm-logTrigger-workflow-%s-%04d", chainID, rand.Intn(10000))
 		lggr.Info().Msgf("About to deploy Workflow %s on chain %s", workflowName, chainID)
 		t_helpers.CompileAndDeployWorkflow(t, testEnv, lggr, workflowName, &workflowConfig, workflowFileLocation)
 
-		time.Sleep(30 * time.Second) // wait for trigger to be registered
+		triggersUpAndRunning := "Trigger RunSimpleEvmLogTriggerWorkflow called"
+		err := t_helpers.AssertBeholderMessage(listenerCtx, t, triggersUpAndRunning, lggr, messageChan, kafkaErrChan, 4*time.Minute)
+		require.NoError(t, err, "LogTrigger capability test failed, Beholder should not return an error")
+
+		// wait for trigger to be registered across the workflow engine of all workflow nodes
+		time.Sleep(10 * time.Second)
 
 		message := "Data for log trigger"
-		startBlock := emitEvent(t, lggr, chainID, bcOutput, msgEmitter, message, workflowConfig)
-		evmChain := bcOutput.(*evm.Blockchain)
-		validateWorkflowExecution(t, lggr, testEnv, evmChain, workflowName, common.HexToAddress(workflowConfig.Addresses[0]), startBlock)
+		_ = emitEvent(t, lggr, chainID, bcOutput, msgEmitter, message, workflowConfig)
+		expectedUserLog := "OnTrigger decoded message: message:" + message
+		err = t_helpers.AssertBeholderMessage(listenerCtx, t, expectedUserLog, lggr, messageChan, kafkaErrChan, 4*time.Minute)
+		require.NoError(t, err, "Expected user log test failed")
 
 		lggr.Info().Msgf("🎉 LogTrigger Workflow %s executed successfully on chain %s", workflowName, chainID)
 		successfulLogTriggerChains = append(successfulLogTriggerChains, chainID)