@@ -311,11 +311,17 @@ func connectTriggerDB(t *testing.T, nodeSets []*cre.NodeSet, chainID string) *sq
311311 return db
312312}
313313
314+ var _ = connectTriggerDB
315+
314316type tableStats struct {
315317 inserts int64
316318 deletes int64
317319}
318320
321+ var _ tableStats
322+
323+ var _ = snapshotTriggerStats
324+
319325// snapshotTriggerStats returns the current cumulative insert/delete counts for
320326// the trigger_pending_events table from pg_stat_user_tables.
321327func snapshotTriggerStats (ctx context.Context , db * sql.DB ) (tableStats , error ) {
@@ -357,11 +363,12 @@ func ExecuteEVMLogTriggerTest(t *testing.T, testEnv *ttypes.TestEnvironment) {
357363
358364 successfulLogTriggerChains := make ([]string , 0 , len (chainsToTest ))
359365 for chainID , bcOutput := range chainsToTest {
360- triggerDB := connectTriggerDB (t , testEnv .Config .NodeSets , chainID )
366+ // TODO: (CRE-2314) Re-enable trigger event ACKS
367+ // triggerDB := connectTriggerDB(t, testEnv.Config.NodeSets, chainID)
361368
362- baselineStats , err := snapshotTriggerStats (t .Context (), triggerDB )
363- require .NoError (t , err , "failed to snapshot trigger_pending_events stats for chain %s" , chainID )
364- t . Logf ("baseline trigger_pending_events stats for chain %s: inserts=%d deletes=%d" , chainID , baselineStats .inserts , baselineStats .deletes )
369+ // baselineStats, err := snapshotTriggerStats(t.Context(), triggerDB)
370+ // require.NoError(t, err, "failed to snapshot trigger_pending_events stats for chain %s", chainID)
371+ // lggr.Info().Msgf ("baseline trigger_pending_events stats for chain %s: inserts=%d deletes=%d", chainID, baselineStats.inserts, baselineStats.deletes)
365372
366373 lggr .Info ().Msgf ("Creating EVM LogTrigger workflow configuration for chain %s" , chainID )
367374 workflowConfig , msgEmitter := configureEVMLogTriggerWorkflow (t , lggr , bcOutput )
@@ -399,7 +406,8 @@ func ExecuteEVMLogTriggerTest(t *testing.T, testEnv *ttypes.TestEnvironment) {
399406 t_helpers .WatchWorkflowLogs (t , lggr , userLogsCh , baseMessageCh , t_helpers .WorkflowEngineInitErrorLog , expectedUserLog , 4 * time .Minute )
400407 emitCancelFn ()
401408
402- verifyTriggerEventACKs (t , triggerDB , baselineStats )
409+ // TODO: (CRE-2314) Re-enable trigger event ACKS
410+ // verifyTriggerEventACKs(t, triggerDB, baselineStats)
403411
404412 lggr .Info ().Msgf ("🎉 LogTrigger Workflow %s executed successfully on chain %s" , workflowName , chainID )
405413 successfulLogTriggerChains = append (successfulLogTriggerChains , chainID )
@@ -429,3 +437,5 @@ func verifyTriggerEventACKs(t *testing.T, triggerDB *sql.DB, baselineStats table
429437 return newInserts > 0 && newDeletes > 0
430438 }, 2 * time .Minute , time .Second , "trigger events were never inserted and/or ACKed in the database" )
431439}
440+
441+ var _ = verifyTriggerEventACKs
0 commit comments