Resource Job Execution

I’m in need of tracking which thread id of the servicing thread (if possible) of a resource job. The thought is to use that thread id as a channel name for Snowpipe streaming insertion. By doing that, it would allow me to use parallel processing without mangling the ‘next_token’ from Snowflake that keeps the inserts aligned.

Seems like one of the ‘ID’s in the execution block of my payload might be tracking that. Can you confirm if any of these parameters identify the servicing thread?

If I understand what you mean by “thead id” correctly, I believe what you are looking for is the value in data.execution.id - that is the ID of the current execution of the resource job - so it would remain the same for a given execution of a resource job across all the iterations. Let me know if that helps!