Weight adjusted dynamic task propagation
First Claim
1. A method, comprising:
- performing operations as follows on a processor of a workload scheduling computing device;
receiving, via a communication network, a plurality of workload parameters from a plurality of workload agents in communication with the workload scheduling computing device, wherein the workload parameters relate to available capacities of the plurality of workload agents and wherein the workload agents comprise computing nodes configured to perform data processing tasks;
identifying a primary workload agent from the plurality of workload agents based on at least one of the plurality of workload parameters;
identifying a plurality of candidate secondary workload agents from among the plurality of workload agents, wherein identifying the candidate secondary workload agents comprises identifying workload agents for which each of the workload parameters is greater than a respective threshold level;
identifying a secondary workload agent from among the plurality of candidate secondary workload agents based on the plurality of workload parameters that are greater than the respective threshold level and an evaluation of a selection function that mathematically evaluates the plurality of workload parameters to select a workload agent from among the candidate secondary workload agents; and
transmitting, via the communication network, a job message that contains a command for the primary workload agent to perform a data processing task, wherein the job message includes a forwarding map that identifies the secondary workload agent and that enables the primary workload agent to perform the data processing task using resources of the secondary workload agent without disrupting future operations of the workload scheduling computing device;
wherein the selection function comprises a weight adjusted function based on a root mean square of a weighted mean of the plurality workload parameters, wherein weights of the weighted mean are assigned to each of the respective workload parameters.
1 Assignment
0 Petitions
Accused Products
Abstract
A method of assigning data processing tasks to workload agents includes receiving workload parameters that relate to available capacities of a plurality of workload agents, identifying a primary workload agent based on at least one of the workload parameters; identifying a plurality of candidate secondary workload agents; identifying a secondary workload agent based on the plurality of workload parameters; and transmitting a job message that contains a command for the primary workload agent to perform a data processing task. The job message includes a forwarding map that identifies the secondary workload agent, and contains a command for the primary workload agent to perform the data processing task using resources of the secondary workload agent.
10 Citations
16 Claims
-
1. A method, comprising:
-
performing operations as follows on a processor of a workload scheduling computing device; receiving, via a communication network, a plurality of workload parameters from a plurality of workload agents in communication with the workload scheduling computing device, wherein the workload parameters relate to available capacities of the plurality of workload agents and wherein the workload agents comprise computing nodes configured to perform data processing tasks; identifying a primary workload agent from the plurality of workload agents based on at least one of the plurality of workload parameters; identifying a plurality of candidate secondary workload agents from among the plurality of workload agents, wherein identifying the candidate secondary workload agents comprises identifying workload agents for which each of the workload parameters is greater than a respective threshold level; identifying a secondary workload agent from among the plurality of candidate secondary workload agents based on the plurality of workload parameters that are greater than the respective threshold level and an evaluation of a selection function that mathematically evaluates the plurality of workload parameters to select a workload agent from among the candidate secondary workload agents; and transmitting, via the communication network, a job message that contains a command for the primary workload agent to perform a data processing task, wherein the job message includes a forwarding map that identifies the secondary workload agent and that enables the primary workload agent to perform the data processing task using resources of the secondary workload agent without disrupting future operations of the workload scheduling computing device; wherein the selection function comprises a weight adjusted function based on a root mean square of a weighted mean of the plurality workload parameters, wherein weights of the weighted mean are assigned to each of the respective workload parameters. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. A workload scheduling computer system, comprising:
-
a processor; and a memory coupled to the processor, the memory comprising computer readable program code embodied therein that, when executed by the processor, causes the processor to perform operations comprising; receiving, via a communication network, a plurality of workload parameters from a plurality of workload agents in communication with the workload scheduling computing device, wherein the workload parameters relate to available capacities of the plurality of workload agents and wherein the workload agents comprise computing nodes configured to perform data processing tasks; identifying a primary workload agent from the plurality of workload agents based on at least one of the plurality of workload parameters; identifying a plurality of candidate secondary workload agents from among the plurality of workload agents, wherein identifying the candidate secondary workload agents comprises identifying workload agents for which each of the workload parameters is greater than a respective threshold level; identifying a secondary workload agent from among the plurality of candidate secondary workload agents based on the plurality of workload parameters that are greater than the respective threshold level and an evaluation of a selection function that mathematically evaluates the plurality of workload parameters to select a workload agent from among the candidate secondary workload agents; and transmitting, via the communication network, a job message that contains a command for the primary workload agent to perform a data processing task, wherein the job message includes a forwarding map that identifies the secondary workload agent and that enables the primary workload agent to perform the data processing task using resources of the secondary workload agent without disrupting future operations of the workload scheduling computing device; wherein the selection function comprises a weight adjusted function based on a root mean square of a weighted mean of the plurality workload parameters, wherein weights of the weighted mean are assigned to each of the respective workload parameters.
-
-
12. A method of assigning data processing tasks to workload agents, comprising:
-
performing operations as follows on a processor of a workload scheduling computing device; receiving, via a communication network, a plurality of workload parameters from a plurality of workload agents in communication with the workload scheduling computing device, wherein the workload parameters relate to available capacities of the plurality of workload agents; identifying a primary workload agent from the plurality of workload agents based on at least one of the plurality of workload parameters, wherein the plurality of workload parameters comprises a workload capacity, and wherein identifying the primary workload agent comprises determining which of the plurality of workload agents has a lowest workload capacity; identifying a plurality of candidate secondary workload agents from among the plurality of workload agents by determining path lengths from the primary workload agent to the plurality of workload agents based on a number of communication nodes between the primary workload agent and each of the plurality of workload agents and selecting workload agents having a path length to the primary workload agent that is less than a threshold path length as the candidate secondary workload agents; identifying a secondary workload agent from among the plurality of candidate secondary workload agents by evaluating a selection function based on; - View Dependent Claims (13, 14, 15, 16)
-
Specification