Addressed Lint errors

core/capabilities/triggers/logevent/service.go

@@ -138,6 +138,9 @@ func (s *TriggerService) Start(ctx context.Context) error {
 // After this call the Service cannot be started again,
 // The service will need to be re-built to start scheduling again.
 func (s *TriggerService) Close() error {
+	for _, trigger := range s.triggers.ReadAll() {
+		trigger.Stop()
+	}
 	return nil
 }
 

core/capabilities/triggers/logevent/service_test.go

@@ -5,11 +5,11 @@ import (
 	"testing"
 	"time"
 
-	commontypes "github.com/smartcontractkit/chainlink-common/pkg/types"
-	commonmocks "github.com/smartcontractkit/chainlink-common/pkg/types/core/mocks"
+	"github.com/stretchr/testify/mock"
 	"github.com/stretchr/testify/require"
-	"github.com/test-go/testify/mock"
 
+	commontypes "github.com/smartcontractkit/chainlink-common/pkg/types"
+	commonmocks "github.com/smartcontractkit/chainlink-common/pkg/types/core/mocks"
 	"github.com/smartcontractkit/chainlink/v2/core/capabilities/testutils"
 	"github.com/smartcontractkit/chainlink/v2/core/capabilities/triggers/logevent"
 	coretestutils "github.com/smartcontractkit/chainlink/v2/core/internal/testutils"
@@ -57,7 +57,7 @@ func TestLogEventTriggerEVMHappyPath(t *testing.T) {
 
 	// Send a blockchain transaction that emits logs
 	go func() {
-		_, err :=
+		_, err =
 			th.LogEmitterContract.EmitLog1(th.BackendTH.ContractsOwner, []*big.Int{big.NewInt(expectedLogVal)})
 		require.NoError(t, err)
 		th.BackendTH.Backend.Commit()
@@ -67,14 +67,16 @@ func TestLogEventTriggerEVMHappyPath(t *testing.T) {
 	// Wait for logs with a timeout
 	_, output, err := testutils.WaitForLog(th.BackendTH.Lggr, log1Ch, 5*time.Second)
 	require.NoError(t, err)
+	err = testutils.PrintMap(output, "EmitLog", th.BackendTH.Lggr)
+	require.NoError(t, err)
 	// Verify if valid cursor is returned
 	cursor, err := testutils.GetStrVal(output, "Cursor")
 	require.NoError(t, err)
-	require.True(t, len(cursor) > 130)
+	require.True(t, len(cursor) > 60)
 	// Verify if Arg0 is correct
 	actualLogVal, err := testutils.GetBigIntValL2(output, "Data", "Arg0")
 	require.NoError(t, err)
 	require.Equal(t, expectedLogVal, actualLogVal.Int64())
 
-	testutils.PrintMap(output, "EmitLog", th.BackendTH.Lggr)
+	logEventTriggerService.Close()
 }

core/capabilities/triggers/logevent/trigger.go

@@ -8,6 +8,7 @@ import (
 	"sync"
 	"time"
 
+	"github.com/ethereum/go-ethereum/common/math"
 	"github.com/smartcontractkit/chainlink-common/pkg/capabilities"
 	"github.com/smartcontractkit/chainlink-common/pkg/logger"
 	"github.com/smartcontractkit/chainlink-common/pkg/types"
@@ -87,8 +88,12 @@ func newLogEventTrigger(ctx context.Context,
 	}
 
 	// Setup callback channel, logger and ticker to poll ContractReader
-	callbackCh := make(chan capabilities.TriggerResponse)
-	ticker := time.NewTicker(time.Duration(int64(logEventConfig.PollPeriod)) * time.Millisecond)
+	callbackCh := make(chan capabilities.TriggerResponse, defaultSendChannelBufferSize)
+	pollPeriod := int64(1000) // default pollPeriod is 1s
+	if logEventConfig.PollPeriod <= math.MaxInt64 {
+		pollPeriod = int64(logEventConfig.PollPeriod)
+	}
+	ticker := time.NewTicker(time.Duration(pollPeriod) * time.Millisecond)
 	done := make(chan bool)
 	lggr, err := logger.New()
 	if err != nil {