cancel
Showing results forย 
Search instead forย 
Did you mean:ย 

Order of Execution Not Right

NAl
Contributor

Hello,

A pipleine Iโ€™m working on seems to attempt to execute the Upsert Content (2) snap before the Create Deal/Job snap is executed. Since the Content record is a child of the Deal/Job, the absence of the Deal/Job Id is causing the Upsert Content (2) to fail.

Iโ€™ve tried to route the documents down the one branch but the pipeline fails because Salesforce (the endpoint), doesnโ€™t recognise the additional variables in the Map Deal/Job snap if the Pass Through option is selected.

Iโ€™m not sure how to best approach this.
Please note my understanding of SnapLogic is beginner level and Iโ€™m not a developer by trade.

Screenshot 2022-05-06 at 11.06.58

8 REPLIES 8

bojanvelevski
Valued Contributor

What is the Join type?

NAl
Contributor

Screenshot 2022-05-06 at 11.41.04

NAl
Contributor

Just seen this on the Join Snap article here:

Known Issue : When the upstream Snaps of the Join Snap contains Copy, Router, Aggregate, or similar Snaps, it is likely that the data flow of a branch in a Pipeline gets blocked until another branch completes streaming the document. The Join Snap might hang if its upstream Snaps in a Pipeline has a blocked branch.

Workaround : Set Sorted streams to Unsorted in the Join Snap to effectively buffer all documents in all input views internallyโ€”this unblocks the document flow of all the upstream branches. The internal sorters sort the input documents from the input views into the local temporary stage.

Iโ€™ll do some investigating

koryknick
Employee
Employee

@NAl - if you want all the data to be inserted into the Create Deal/Job before any data is sent to the Upsert Content, you could simply place a Sort just before the Upsert. This will effectively cache all the data until the upstream snaps have completed.

You are basically running into a race condition where the Deal/Job records may not have been committed to the database before the Upsert Content tries to insert a new record that is reliant on that relationship.