SubmitQueryJob 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-salesforce-processors-nar
Description¶
Submits a Query Job to Salesforce using the Bulk API 2.0.
Input Requirement¶
ALLOWED
Supports Sensitive Dynamic Properties¶
false
Properties¶
Property |
Description |
|---|---|
Column Delimiter |
The column delimiter used for CSV job data. |
Configuration Mode |
The configuration mode for configuring this processor. If using advanced mode, the SOQL query has to be provided and theprocessor’s state will only store the timestamp of the last query job submission regardless of the object queried. If usingsimple mode, the object name and the fields to be queried have to be provided and the processor’s state will store thetimestamp of the last query job submission for each object queried. |
Incremental Offload |
Whether the processor should perform incremental offload. If true, the processor willonly fetch the records that have been modified since the last query job submission byusing a WHERE clause on the SystemModstamp field. |
Line Ending |
The line ending used for CSV job data, marking the end of a data row. |
Object Fields |
Comma separated list of the name of the fields to be queried for the specified object. |
Object Name |
The name of the object to be queried. |
Operation |
The type of query to submit. |
Query |
The query to be performed. In order to perform incremental retrieval (ie. only the added/modified/deleted elements since the last submission of the query are retrieved), this processor exposes two attributes: ${nowTs} and ${lastJobTimestamp}. It is possible to use those placeholders like SELECT Id FROM Account WHERE SystemModstamp > ${lastJobTimestamp} AND SystemModstamp <= ${nowTs}. |
Result Format |
The format to be used for the results. Currently the only supported value is CSV. |
Salesforce Client |
Salesforce Client to interact with the APIs |
State management¶
Scopes |
Description |
|---|---|
CLUSTER |
In case the placeholders for incremental retrieval are used in the query field, the timestamp of the last Query Job submission time minus 30 seconds will be stored in the state. |
Relationships¶
Name |
Description |
|---|---|
comms.failure |
An incoming FlowFile is routed to this relationship if the Query Job could not be submitted but the operation might be retried |
failure |
An incoming FlowFile is routed to this relationship if the Query Job could not be submitted |
success |
When a Query Job is successfully submited, a FlowFile is routed to this relationship |
Writes attributes¶
Name |
Description |
|---|---|
jobId |
The unique ID for this job. |
operationType |
The type of query. |
objectType |
The object type being queried. |
createdById |
The ID of the user who created the job. |
createdDate |
The UTC date and time when the job was created. |
systemModstamp |
The UTC date and time when the API last updated the job information. |
jobState |
The current state of processing for the job. |
concurrencyMode |
How the request is processed. |
contentType |
The format to be used for the results. |
apiVersion |
The API version that the job was created in. |
lineEnding |
The line ending used for CSV job data, marking the end of a data row. |
columnDelimiter |
The column delimiter used for CSV job data. |
Use cases¶
Submits a Query Job to Salesforce using the Bulk API 2.0. |