US Patent 11907676 Processing orchestration for systems including distributed components

Techniques for implementing a streaming remote procedure call (RPC) mechanism using distributed processing components of a system are described. A first processing component sends a connect message to a second processing component. Thereafter, the first processing component sends different instances of data to the second processing component as the different instances of data are determined by the first processing component. The second processing component performs at least some processes as the second processing component receives the different instances of data. After the first processing component sends all relevant data to the second processing component, the first processing component sends a commit message to the second processing component. Based at least in part on receiving the commit message, the second processing component determines finishes its processing, and sends result data to the first processing component.