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

Queueing Data for a Pipeline Execute

jamesv
New Contributor II

I want to call an external service in a pipeline execute that can only run a single call at a time, but each document I could conceivably call against it can actually be aggregated and passed in a batch call.

Is there any way to queue documents up and collapse them until the pipeline execute is finished running, then submit those documents to the pipeline execute?

Currently the only way I can think to do this is to simply group documents by a predefined number at a time, but the pipeline execute thatโ€™s sending data to the endpoint could conceivably support much more than the batch size at a time to hand off.

1 REPLY 1

tstack
Former Employee

Yes, I think using the GroupByN snap is the only way to do this at the moment.

Iโ€™ve filed a feature request for this.