diff --git a/router/batchrouter/asyncdestinationmanager/klaviyobulkupload/klaviyobulkupload.go b/router/batchrouter/asyncdestinationmanager/klaviyobulkupload/klaviyobulkupload.go index 5582ff5ced..015e2cb025 100644 --- a/router/batchrouter/asyncdestinationmanager/klaviyobulkupload/klaviyobulkupload.go +++ b/router/batchrouter/asyncdestinationmanager/klaviyobulkupload/klaviyobulkupload.go @@ -17,6 +17,7 @@ import ( backendconfig "github.com/rudderlabs/rudder-server/backend-config" "github.com/rudderlabs/rudder-server/jobsdb" "github.com/rudderlabs/rudder-server/router/batchrouter/asyncdestinationmanager/common" + obskit "github.com/rudderlabs/rudder-observability-kit/go/labels" ) const ( @@ -118,11 +119,12 @@ func (kbu *KlaviyoBulkUploader) Poll(pollInput common.AsyncPoll) common.PollStat allComplete = false pollresp, err := kbu.KlaviyoAPIService.GetUploadStatus(importId) if err != nil { + kbu.Logger.Errorn("Error during fetching Klaviyo Bulk Upload status", obskit.Error(err)) return common.PollStatusResponse{ - StatusCode: 400, + StatusCode: 500, Complete: true, HasFailed: true, - Error: `Error during fetching upload status `+ err.Error(), + Error: `Error during fetching upload status ` + err.Error(), } }