updated executePoll method to be accesible by integrations

Author: arnav777dev

packages/core/src/destination-kit/index.ts

@@ -723,7 +723,7 @@ export class Destination<Settings = JSONObject, AudienceSettings = JSONObject> {
     return action.executeDynamicField(fieldKey, data, dynamicFn)
   }
 
-  public async executePollStatus(
+  public async executePoll(
     actionSlug: string,
     {
       event,

packages/destination-actions/src/destinations/salesforce-marketing-cloud/asyncDataExtension/index.ts

@@ -108,20 +108,22 @@ const action: ActionDefinition<Settings, Payload, unknown, unknown, unknown, Pol
     const pollResult = await pollAsyncOperation(request, settings.subdomain, operationId)
 
     // Map SFMC status to framework status
+    // Check both requestStatus (Complete/InProcess/etc) and resultStatus (OK/Error)
     let status: 'pending' | 'completed' | 'failed'
-    switch (pollResult.status) {
-      case 'Complete':
-        status = 'completed'
-        break
-      case 'Failed':
-      case 'Error':
+    const sfmcStatus = pollResult.results as any
+
+    if (pollResult.status === 'Complete') {
+      // Request finished - check if it succeeded or had errors
+      if (sfmcStatus?.hasErrors || sfmcStatus?.resultStatus === 'Error') {
         status = 'failed'
-        break
-      case 'InProcess':
-      case 'Queued':
-      default:
-        status = 'pending'
-        break
+      } else {
+        status = 'completed'
+      }
+    } else if (pollResult.status === 'Failed' || pollResult.status === 'Error') {
+      status = 'failed'
+    } else {
+      // InProcess, Queued, etc.
+      status = 'pending'
     }
 
     const results = pollResult.results || {}

packages/destination-actions/src/destinations/salesforce-marketing-cloud/sfmc-operations.ts

@@ -109,7 +109,16 @@ export async function pollAsyncOperation(
       status: data.status.requestStatus,
       operationId: operationId,
       completedAt: data.status.completionDateTime,
-      errorMessage: data.status.hasErrors ? 'Operation completed with errors' : undefined
+      errorMessage: data.status.hasErrors ? 'Operation completed with errors' : undefined,
+      results: {
+        requestStatus: data.status.requestStatus,
+        resultStatus: data.status.resultStatus,
+        hasErrors: data.status.hasErrors,
+        resultMessages: data.resultMessages || [],
+        callDateTime: data.status.callDateTime,
+        pickupDateTime: data.status.pickupDateTime,
+        completionDateTime: data.status.completionDateTime
+      }
     }
   } catch (error) {
     console.log('poll error', error)
@@ -162,6 +171,7 @@ export async function asyncUpsertRowsV2(
       json: { items: rows }
     }
   )
+  console.log('no multistatsus')
   return response
 }