Merge pull request #1206 from ashitsalesforce/master

fix for W-16422132
forcedotcom · Aug 5, 2024 · d8dbb1f · d8dbb1f
2 parents 38a2be8 + 1b8e8ab
commit d8dbb1f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/salesforce/dataloader/action/visitor/BulkV2Connection.java b/src/main/java/com/salesforce/dataloader/action/visitor/BulkV2Connection.java
@@ -364,7 +364,7 @@ public JobInfo createJob(JobInfo job) throws AsyncApiException {
 
     	HashMap<String, Object> requestBodyMap = new HashMap<String, Object>();
     	requestBodyMap.put("operation", job.getOperation().toString());
-        if (operation.equals(OperationEnum.query)) {
+        if (controller.getConfig().getOperationInfo().isExtraction()) {
         	headers = getHeaders(JSON_CONTENT_TYPE, CSV_CONTENT_TYPE);
         	requestBodyMap.put("query", job.getObject());        	
         } else {