Update error handling

segmentio · Nov 29, 2023 · ad48899 · ad48899
1 parent e9f2370
commit ad48899
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 14 deletions.
diff --git a/packages/destination-actions/src/destinations/klaviyo/upsertProfile/__tests__/index.test.ts b/packages/destination-actions/src/destinations/klaviyo/upsertProfile/__tests__/index.test.ts
@@ -365,6 +365,6 @@ describe('Upsert Profile Batch', () => {
         events,
         useDefaultMappings: true
       })
-    ).rejects.toThrow('An error occurred while processing the request')
+    ).rejects.toThrow()
   })
 })
diff --git a/packages/destination-actions/src/destinations/klaviyo/upsertProfile/index.ts b/packages/destination-actions/src/destinations/klaviyo/upsertProfile/index.ts
@@ -203,20 +203,15 @@ const action: ActionDefinition<Settings, Payload> = {
     let importResponseWithList
     let importResponseWithoutList
 
-    try {
-      if (profilesWithList.length > 0) {
-        const listId = profilesWithList[0].list_id
-        const importJobPayload = createImportJobPayload(profilesWithList, listId)
-        importResponseWithList = await sendImportJobRequest(request, importJobPayload)
-      }
+    if (profilesWithList.length > 0) {
+      const listId = profilesWithList[0].list_id
+      const importJobPayload = createImportJobPayload(profilesWithList, listId)
+      importResponseWithList = await sendImportJobRequest(request, importJobPayload)
+    }
 
-      if (profilesWithoutList.length > 0) {
-        const importJobPayload = createImportJobPayload(profilesWithoutList)
-        importResponseWithoutList = await sendImportJobRequest(request, importJobPayload)
-      }
-    } catch (error) {
-      console.error('Error processing batch:', error)
-      throw new Error('An error occurred while processing the request')
+    if (profilesWithoutList.length > 0) {
+      const importJobPayload = createImportJobPayload(profilesWithoutList)
+      importResponseWithoutList = await sendImportJobRequest(request, importJobPayload)
     }
 
     return {