公开(公告)号：US20220345390A1

公开(公告)日：2022-10-27

申请号：US17237582

申请日：2021-04-22

Applicant: salesforce.com, inc.

Inventor： Jeffrey Hajewski ,  Victor Spivak ,  Alexander Oscherov ,  Stefan Derdak

IPC: H04L12/26 ,  H04L29/08

Abstract: System and methods are described for performing sequences of computations in an infrastructure-agnostic manner. In one implementation, a method comprises: receiving a dispatch request for executing a user-defined pipeline; computing a performance metric based on the dispatch request; and determining, based at least partially on the performance metric, whether to execute the user-defined pipeline locally by the pipeline engine or transmit the dispatch request back to the network adapter.

公开(公告)号：US20220300416A1

公开(公告)日：2022-09-22

申请号：US17206633

申请日：2021-03-19

Applicant: Salesforce.com, Inc.

Inventor： Jeffrey HAJEWSKI ,  Stefan Derdak

IPC: G06F12/02 ,  G06F16/901

Abstract: Disclosed are some implementations of systems, apparatus, methods and computer program products for generating and implementing computational graphs that facilitate concurrent computation on data streams. A computational graph includes a plurality of nodes, where each node has one or more stages associated therewith. Each stage may be associated with a corresponding operation that is to be performed on data associated with that stage.

公开(公告)号：US10853154B2

公开(公告)日：2020-12-01

申请号：US16262874

申请日：2019-01-30

Applicant: salesforce.com, inc.

Inventor： Stefan Derdak ,  Reuben Cornel ,  Hormoz Tarevern ,  Richard Perry Pack, III

IPC: G06F3/00 ,  G06F9/54

Abstract: A method is provided for orchestrating a workflow. In some embodiments, the method includes executing a workflow including a first controller that includes a first callout function and a first callback function and corresponds to a first microservice. Execution of the workflow includes execution of the first callout function that causes invocation of the first call to the first microservice. The method further includes receiving a notification of an execution state from the first microservice and transmitting the execution state to the first callback function. The method also includes in response to transmitting the execution state to the first callback function, receiving a function output based on the execution state from the first callback function. The method further includes determining, based on the function output, whether to execute a subsequent controller. The method also includes in response to a determination to execute the subsequent controller, executing the subsequent controller.