Granted Patent B2

US 12,436,819 · App. 18/633,570 · Granted Oct 7, 2025

Inventors: Jieyi Long (Santa Clara, CA); Mitchell C. Liu (Los Altos, CA)

Assignee: Theta Labs, Inc.

G06F9/5083G06F9/4881H04L9/3218

Abstract

Claims (72)

1. A non-transitory computer-readable storage medium having instructions stored therein, which when executed by a processor, cause a coordinator cluster of a cloud-edge computing platform to execute steps comprising:

receive, at the coordinator cluster, a data file associated with a workload;

wherein the workload comprises a first compute task and a second compute task,

wherein the data file comprises a first task metadata for the first compute task and a second task metadata for the second compute task;

select, by the coordinator cluster, a first shard in the cloud-edge computing platform based on the first task metadata and a second shard in the cloud-edge computing platform based on the second task metadata,

wherein the selected first shard is an edge-based network on the cloud-edge computing platform, wherein the edge-based network comprises a decentralized blockchain-based network,

wherein the coordinator cluster comprises a task initiator node of the edge-based network, and

wherein the selected second shard is a cloud-based network on the cloud-edge computing platform;

compute, by the coordinator cluster, for each of one or more worker nodes in the selected first shard, a first efficiency score, and for each of one or more worker nodes in the selected second shard, a second efficiency score,

wherein the first efficiency score for the each of the one or more worker nodes in the selected first shard depends at least on the first task metadata and one or more characteristics of the each of the one or more worker nodes in the selected first shard, and

wherein the second efficiency score for the each of the one or more worker nodes in the selected second shard depends at least on the second task metadata and one or more characteristics of the each of the one or more worker nodes in the selected second shard;

select, by the coordinator cluster, a selected first plurality of worker nodes in the selected first shard to execute the first compute task, based on the first efficiency scores of each of the selected first plurality of worker nodes in the selected first shard,

wherein the selected first shard comprises a master cluster,

wherein the master cluster belongs to the first shard and is distinct from the coordinator cluster,

wherein the master cluster orchestrates the first compute task among the selected first plurality of worker nodes in the selected first shard, and

wherein the master cluster orchestrates by distributing the first compute task among the selected first plurality of worker nodes in the selected first shard; and

wherein the selected first plurality of worker nodes in the selected first shard are edge computing nodes in the edge-based network;

select, by the coordinator cluster, a selected second plurality of worker nodes in the selected second shard to execute the second compute task, based on the second efficiency scores of each of the selected second plurality of worker nodes in the selected second shard;

register, by the task initiator node, the first compute task by invoking a smart contract on a blockchain associated with the edge-based network;

route, by the coordinator cluster, the first compute task and at least a first portion of the data file associated with the workload to the selected first shard and the selected first plurality of worker nodes in the selected first shard;

receive, by the coordinator cluster, a first task solution for the first compute task, from the selected first shard and the selected first plurality of worker nodes in the selected first shard;

verify, by the coordinator cluster, the first task solution for the first compute task;

route, by the coordinator cluster, the second compute task, the first task solution, and at least a second portion of the data file associated with the workload to the selected second shard and the selected second plurality of worker nodes in the selected second shard;

receive, by the coordinator cluster, a second task solution for the second compute task, from the selected second shard and the selected second plurality of worker nodes in the selected second shard;

verify, by the coordinator cluster, the second task solution for the second compute task;

invoke, by the task initiator node, the smart contract to transfer a first reward to the selected first plurality of worker nodes in the selected first shard upon successful verification of the first task solution,

wherein the first reward is from a reward pool on the blockchain; and

transfer, by the coordinator cluster, a second reward to the selected second plurality of worker nodes in the selected second shard upon successful verification of the second task solution.

2. The non-transitory computer-readable storage medium of claim 1 , wherein the first task solution is encrypted by the selected first plurality of worker nodes in the selected first shard, wherein a zero-knowledge proof of the first task solution is provided by the selected first plurality of worker nodes in the selected first shard, and wherein the verifying of the first task solution by the coordinator cluster further comprises verifying the zero-knowledge proof of the first task solution.

3. The non-transitory computer-readable storage medium of claim 1 , wherein the first reward is calculated by the coordinator cluster based on factors comprising one or more of a job type, a correctness of the first task solution, a first task completion time, and a resource usage of the selected first plurality of worker nodes in the selected first shard.

4. The non-transitory computer-readable storage medium of claim 1 , the storage medium further comprising instructions to:

provide feedback, by the coordinator cluster, to a user, wherein the feedback comprises at least one of a workload completion status, a cryptocurrency amount associated with the first reward, an owner of the workload, a status of the workload, and an identifier associated with the workload.

5. The non-transitory computer-readable storage medium of claim 1 , wherein the one or more shards in the cloud-edge computing platforms are part of a multi-shard architecture comprising at least one of a community shard with edge worker nodes, a managed shard with managed cloud nodes, and a partner shard with partner-hosted cloud nodes.

6. The non-transitory computer-readable storage medium of claim 1 , wherein the first compute task is a generic containerized compute task.

7. The non-transitory computer-readable storage medium of claim 1 , wherein the workload comprises an artificial intelligence task.

8. The non-transitory computer-readable storage medium of claim 1 , wherein the workload comprises a video processing task.

9. The non-transitory computer-readable storage medium of claim 1 , wherein the cloud-edge computing platform comprises a distributed storage component that supports temporal, persistent, and immutable storage use cases.

10. The non-transitory computer-readable storage medium of claim 1 , wherein the selected first plurality of worker nodes in the selected first shard accesses data from a distributed vector database in the cloud-edge computing platform to compute the first task solution for the first compute task.

11. The non-transitory computer-readable storage medium of claim 1 , wherein first task metadata comprises privacy requirements.

12. The non-transitory computer-readable storage medium of claim 1 , wherein one of the first compute task and the second compute task comprises a proprietary model accessible through an application programming interface (API).

13. A method for hybrid cloud-edge computing in a cloud-edge computing platform, the method comprising:

receiving, at a coordinator cluster of the cloud-edge computing platform, a data file associated with a workload,

wherein the workload comprises a first compute task and a second compute task,

wherein the data file comprises a first task metadata for the first compute task and a second task metadata for the second compute task;

selecting, by the coordinator cluster, a first shard in the cloud-edge computing platform based on the first task metadata and a second shard in the cloud-edge computing platform based on the second task metadata,

wherein the selected first shard is an edge-based network on the cloud-edge computing platform, wherein the edge-based network comprises a decentralized blockchain-based network,

wherein the coordinator cluster comprises a task initiator node of the edge-based network, and

wherein the selected second shard is a cloud-based network on the cloud-edge computing platform;

computing, by the coordinator cluster, for each of one or more worker nodes in the selected first shard, a first efficiency score, and for each of one or more worker nodes in the selected second shard, a second efficiency score,

wherein the first efficiency score for the each of the one or more worker nodes in the selected first shard depends at least on the first task metadata and one or more characteristics of the each of the one or more worker nodes in the selected first shard, and

wherein the second efficiency score for the each of the one or more worker nodes in the selected second shard depends at least on the second task metadata and one or more characteristics of the each of the one or more worker nodes in the selected second shard;

selecting, by the coordinator cluster, a selected first plurality of worker nodes in the selected first shard to execute the first compute task based on the first efficiency scores of each of the selected first plurality of worker nodes in the selected first shard,

wherein the selected first shard comprises a master cluster,

wherein the master cluster belongs to the first shard and is distinct from the coordinator cluster,

wherein the master cluster orchestrates the first compute task among the selected first plurality of worker nodes in the selected first shard,

wherein the master cluster orchestrates by distributing the first compute task among the selected first plurality of worker nodes in the selected first shard; and

wherein the selected first plurality of worker nodes in the selected first shard are edge computing nodes in the edge-based network;

selecting, by the coordinator cluster, a selected second plurality of worker nodes in the selected second shard to execute the second compute task, based on the efficiency scores of each of the selected second plurality of worker nodes in the selected second shard;

registering, by the task initiator node, the first compute task by invoking a smart contract on a blockchain associated with the edge-based network;

routing, by the coordinator cluster, the first compute task and at least a first portion of the data file associated with the workload to the selected first shard and the selected first plurality of worker nodes in the selected first shard;

receiving, by the coordinator cluster, a first task solution for the first compute task, from the selected first shard and the selected first plurality of worker nodes in the selected first shard;

verifying, by the coordinator cluster, the first task solution for the first compute task,

routing, by the coordinator cluster, the second compute task, the first task solution, and at least a second portion of the data file associated with the workload to the selected second shard and the selected second plurality of worker nodes in the selected second shard;

receiving, by the coordinator cluster, a second task solution for the second compute task, from the selected second shard and the selected second plurality of worker nodes in the selected second shard;

verifying, by the coordinator cluster, the second task solution for the second compute task;

invoking, by the task initiator node, the smart contract to transfer a first reward to the selected first plurality of worker nodes in the selected first shard upon successful verification of the first task solution,

wherein the first reward is from a reward pool on the blockchain; and

transferring, by the coordinator cluster, a second reward to the selected second plurality of worker nodes in the selected second shard upon successful verification of the second task solution.

14. The method of claim 13 , wherein the first task solution is encrypted by the selected first plurality of worker nodes in the selected first shard, wherein a zero-knowledge proof of the first task solution is provided by the selected first plurality of worker nodes in the selected first shard, and wherein the verifying of the first task solution by the coordinator cluster further comprises verifying the zero-knowledge proof of the first task solution.

15. The method of claim 13 , wherein the first reward is calculated by the coordinator cluster based on factors comprising one or more of a job type, a correctness of the first task solution, a first task completion time, and a resource usage of the selected first plurality of worker nodes in the selected first shard.

16. The method of claim 13 , further comprising:

providing feedback, by the coordinator cluster, to a user, wherein the feedback comprises at least one of a workload completion status, a cryptocurrency amount associated with the first reward, an owner of the workload, a status of the workload, and an identifier associated with the workload.

Assignments (1)

Continuity (2)

References Cited (19)