Program flow monitoring and control of an event-triggered system
In various examples, a program (e.g., application, algorithm, routine, etc.) may be organized into operational units (e.g., nodes executed by one or more processors), each of which are tasked with executing one or more respective events (e.g., tasks) within the larger program. At least some of the events of the larger program may be successively executed in a flow, one after another, using triggers sent directly from one node to the next. In addition, a manager may exchange communications with the nodes to monitor or assess a status of the system (e.g., determine when a node has completed an event) or to control or trigger a node to initiate an event.
1 . A method comprising:
monitoring, based at least on an execution graph representative of a program, execution of one or more first tasks of a plurality of tasks of the program, the execution graph including a plurality of nodes corresponding to respective tasks of the plurality of tasks and edges defining an execution flow of the plurality of tasks among the plurality of nodes;
based at least on the monitoring, determining one or more conditions for triggering one or more nodes of the plurality of nodes in the execution graph are satisfied, the one or more conditions corresponding to completion of one or more portions of the one or more first tasks; and
based at least on the determining, transmitting one or more manager-originating triggers to the one or more nodes, wherein the one or more nodes are programmed to enforce, in response to receiving one or more node-originating triggers, an execution order of the plurality of tasks in the execution flow based at least on delaying initiating one or more second tasks of the plurality of tasks until the one or more manager-originating triggers are received.
2 . The method of claim 1 , wherein the one or more conditions include at least one of one or more time-based conditions, one or more resource-based conditions, or one or more status-based conditions.
3 . The method of claim 1 , wherein output of the program is used to direct one or more operations of an autonomous or semi-autonomous machine in an environment.
4 . The method of claim 1 , further comprising prior to initiating the execution flow, programming, based at least on a representation of the execution order, the one or more nodes to, responsive to the receiving of the one or more node-originating triggers, delay the initiating until the one or more manager-originating triggers are received.
5 . The method of claim 1 , wherein the determining the one or more conditions are satisfied uses one or more event reports sent from and generated by at least one of the plurality of nodes, the one or more event reports indicating a start or an end of a task of the one or more first tasks.
6 . The method of claim 1 , wherein the execution is used to control one or more of:
an autonomous or semi-autonomous vehicle;
artificial intelligence-assisted video monitoring;
an artificial intelligence-assisted diagnostic device; or
an artificial intelligence-assisted surgical device.
7 . The method of claim 1 , wherein the transmitting is responsive to detecting the one or more conditions are satisfied.
8 . A system comprising:
one or more combinations of one or more hardware components to execute operations including:
applying sensor data obtained using one or more sensors of a machine in an environment to a program to cause execution of an execution graph representative of the program to detect one or more conditions corresponding to the environment, the execution graph including a plurality of nodes corresponding to respective tasks of a plurality of tasks and edges defining an execution flow of the plurality of tasks among the plurality of nodes; and
based at least on a determination, using one or more status indicators of one or more first tasks of the plurality of tasks that correspond to one or more first nodes of the plurality of nodes, that one or more conditions for triggering one or more second nodes of the plurality of nodes in the execution graph are satisfied, providing one or more manager-originating triggers to the one or more second nodes,
wherein the one or more second nodes are programmed to enforce, in response to receiving one or more node-originating triggers from one or more other nodes of the plurality of nodes, an execution order of the plurality of tasks in the execution flow based at least on delaying initiation of one or more second tasks of the plurality of tasks until the one or more manager-originating triggers are received, the one or more second tasks using the one or more combinations of the one or more hardware components to control the machine in the environment.
9 . The system of claim 8 , wherein output of the program is reflective of one or more environmental conditions corresponding to the environment in real time.
10 . The system of claim 8 , wherein the one or more conditions include at least one of one or more time-based conditions, one or more resource-based conditions, or one or more status-based conditions.
11 . The system of claim 8 , wherein the execution order is predetermined by an ordered representation of the program.
12 . The system of claim 8 , wherein the determination uses one or more event reports sent from and generated by at least one of the one or more first nodes, the one or more event reports indicating a start or an end of a task of the one or more first tasks.
13 . The system of claim 8 , wherein the machine includes one or more of:
an autonomous or semi-autonomous vehicle;
an artificial intelligence-assisted diagnostic device; or
an artificial intelligence-assisted surgical device.
14 . The system of claim 8 , wherein a node of the plurality of nodes represents a discrete hardware component, a computing device, or a computing system.
15 . The system of claim 8 , wherein the system is comprised in at least one of:
a control system for an autonomous or semi-autonomous machine;
a perception system for an autonomous or semi-autonomous machine;
a system implemented using a robot;
a system for performing one or more artificial intelligence-assisted video monitoring operations;
a system for performing one or more artificial intelligence-assisted diagnostic device operations;
a system for performing one or more artificial intelligence-assisted surgical device operations; or
a system for presenting at least one of virtual reality content or augmented reality content.
16 . At least one processor comprising:
one or more circuits to provide one or more manager-originating triggers to one or more nodes of a plurality of nodes in an execution graph representative of a program based at least on:
monitoring, based at least on the execution graph, execution of one or more first tasks of a plurality of tasks of the program, the execution graph including the plurality of nodes corresponding to respective tasks of the plurality of tasks and edges defining an execution flow of the plurality of tasks among the plurality of nodes; and
based at least on the monitoring, determining one or more conditions for triggering the one or more nodes in the execution graph are satisfied, the one or more conditions corresponding to completion of one or more portions of the one or more first tasks, wherein the one or more nodes are programmed to enforce, in response to receiving one or more node-originating triggers from one or more other nodes of the plurality of nodes, an execution order of the plurality of tasks in the execution flow based at least on delaying initiation of one or more second tasks of the plurality of tasks until the one or more manager-originating triggers are received.
17 . The at least one processor of claim 16 , wherein the one or more conditions include at least one of one or more time-based conditions, one or more resource-based conditions, or one or more status-based conditions.
18 . The at least one processor of claim 16 , wherein output of the program is reflective of one or more environmental conditions detected by the program and corresponding to an environment in real time, and the output is used to direct one or more operations of an autonomous or semi-autonomous machine in the environment.
19 . The at least one processor of claim 16 , wherein the delaying causes the one or more nodes to initiate the one or more second tasks after the completion of the one or more first tasks.
20 . The at least one processor of claim 16 , wherein the at least one processor is comprised in at least one of:
a control system for an autonomous or semi-autonomous machine;
a perception system for an autonomous or semi-autonomous machine;
a system implemented using a robot;
a system for performing one or more artificial intelligence-assisted video monitoring operations;
a system for performing one or more artificial intelligence-assisted diagnostic device operations;
a system for performing one or more artificial intelligence-assisted surgical device operations; or
a system for presenting at least one of virtual reality content or augmented reality content.