sf bulk expands references

OpenFn · Feb 29, 2024 · 1113832 · 1113832
1 parent 20d0fba
commit 1113832
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/packages/salesforce/ast.json b/packages/salesforce/ast.json
@@ -342,7 +342,7 @@
         "sObject",
         "operation",
         "options",
-        "fun"
+        "records"
       ],
       "docs": {
         "description": "Create and execute a bulk job.",
@@ -390,12 +390,12 @@
           },
           {
             "title": "param",
-            "description": "A function which takes state and returns an array.",
+            "description": "an array of records, or a function which returns an array.",
             "type": {
               "type": "NameExpression",
               "name": "Function"
             },
-            "name": "fun"
+            "name": "records"
           },
           {
             "title": "returns",

diff --git a/packages/salesforce/src/Adaptor.js b/packages/salesforce/src/Adaptor.js
@@ -327,7 +327,7 @@ export function bulk(sObject, operation, options, records) {
     const { failOnError, allowNoOp, pollTimeout, pollInterval } = options;
 
     const [resolvedSObject, resolvedOperation, resolvedRecords] =
-      expandReferences(state, sObject, operation, records);
+      newExpandReferences(state, sObject, operation, records);
 
     if (allowNoOp && resolvedRecords.length === 0) {
       console.info(
@@ -336,10 +336,10 @@ export function bulk(sObject, operation, options, records) {
       return state;
     }
 
-    if (records.length > 10000)
+    if (resolvedRecords.length > 10000)
       console.log('Your batch is bigger than 10,000 records; chunking...');
 
-    const chunkedBatches = chunk(records, 10000);
+    const chunkedBatches = chunk(resolvedRecords, 10000);
 
     return Promise.all(
       chunkedBatches.map(