US 11,929,901 B2
Infrastructure-agnostic performance of computation sequences
Jeffrey Hajewski, North Liberty, IA (US); Victor Spivak, San Mateo, CA (US); Alexander Oscherov, Danville, CA (US); and Stefan Derdak, San Jose, CA (US)
Assigned to Salesforce, Inc., San Francisco, CA (US)
Filed by Salesforce, Inc., San Francisco, CA (US)
Filed on Apr. 22, 2021, as Appl. No. 17/237,582.
Prior Publication US 2022/0345390 A1, Oct. 27, 2022
Int. Cl. H04L 43/0888 (2022.01); H04L 67/60 (2022.01)
CPC H04L 43/0888 (2013.01) [H04L 67/60 (2022.05)] 17 Claims
OG exemplary drawing
 
1. A computer-implemented method comprising:
receiving, from a network adapter by a pipeline engine of a pipeline architecture, a dispatch request for executing a user-defined pipeline, wherein the dispatch request is agnostic to an underlying network infrastructure by which the user-defined pipeline is to be executed;
computing a performance metric based on the dispatch request and by information extracted from metadata associated with messages exchanged between computational nodes of the pipeline architecture, the performance metric comprising at least an estimate of computational times for local execution;
executing one or more stages of the user-defined pipeline locally by the pipeline engine based on a user-specified requirement, wherein the user-specified requirement overrides decision logic of the pipeline engine in determining whether to execute the stages of the user-defined pipeline locally by the pipeline engine or transmit the dispatch request back to the network adapter; and
determining, based at least partially on the performance metric and an overhead generated through serialization and deserialization of transmitting the dispatch request back to the network adapter, whether to execute the remaining stages of the user-defined pipeline locally by the pipeline engine or transmit the dispatch request back to the network adapter, wherein transmitting the dispatch request requires serialization and deserialization of the dispatch request.