diff --git a/router/batchrouter/asyncdestinationmanager/bing-ads/offline-conversions/bingads_test.go b/router/batchrouter/asyncdestinationmanager/bing-ads/offline-conversions/bingads_test.go index 98985d454d..588beaf2b2 100644 --- a/router/batchrouter/asyncdestinationmanager/bing-ads/offline-conversions/bingads_test.go +++ b/router/batchrouter/asyncdestinationmanager/bing-ads/offline-conversions/bingads_test.go @@ -539,14 +539,14 @@ var _ = Describe("Bing ads Offline Conversions", func() { Expect(err).To(BeNil()) }) - It("Transform() Test -> conversionAdjustedTime not available", func() { + It("Transform() Test -> adjustedConversionTime not available", func() { job := &jobsdb.JobT{ EventPayload: []byte("{\"type\": \"record\", \"action\": \"update\", \"fields\": {\"conversionName\": \"Test-Integration\", \"conversionTime\": \"5/22/2023 6:27:54 AM\", \"conversionValue\": \"100\", \"microsoftClickId\": \"click_id\", \"conversionCurrencyCode\": \"USD\"}}"), } uploader := &BingAdsBulkUploader{} // Execute _, err := uploader.Transform(job) - expectedResult := fmt.Errorf(" conversionAdjustedTime field not defined") + expectedResult := fmt.Errorf(" adjustedConversionTime field not defined") Expect(err.Error()).To(Equal(expectedResult.Error())) }) }) diff --git a/router/batchrouter/asyncdestinationmanager/bing-ads/offline-conversions/bulk_uploader.go b/router/batchrouter/asyncdestinationmanager/bing-ads/offline-conversions/bulk_uploader.go index 7ea421d839..e7cb07f010 100644 --- a/router/batchrouter/asyncdestinationmanager/bing-ads/offline-conversions/bulk_uploader.go +++ b/router/batchrouter/asyncdestinationmanager/bing-ads/offline-conversions/bulk_uploader.go @@ -69,7 +69,7 @@ func (b *BingAdsBulkUploader) Transform(job *jobsdb.JobT) (string, error) { } if event.Action != "insert" { // validate for adjusted time - err := validateField(fields, "conversionAdjustedTime") + err := validateField(fields, "adjustedConversionTime") if err != nil { return payload, err }