公开(公告)号：US20250036464A1

公开(公告)日：2025-01-30

申请号：US18670459

申请日：2024-05-21

Applicant: Snowflake Inc.

Inventor： Gabriel Kliot ,  Ruji Xie ,  Subramanian Muralidhar ,  William Waddington

IPC: G06F9/48

Abstract: Techniques for configuring an asynchronous task queue are disclosed. An example method includes enqueuing, by at least one hardware processor of a first computing node, a task in a task queue. The at least one hardware processor detects a lease request for the task. The lease request is received from a second computing node. The at least one hardware processor initiates a lease of the task to the second computing node. The at least one hardware processor updates a state of the task based on the lease. The at least one hardware processor determines whether to dequeue the task based on a task processing update received from the second computing node.

公开(公告)号：US12032995B1

公开(公告)日：2024-07-09

申请号：US18361549

申请日：2023-07-28

Applicant: Snowflake Inc.

Inventor： Gabriel Kliot ,  Ruji Xie ,  Subramanian Muralidhar ,  William Waddington

IPC: G06F9/48

CPC classification number: G06F9/4881

Abstract: A method includes decoding, by at least one hardware processor, an enqueue request received from a data process of a database system. The enqueue request includes a task. The task is enqueued in an in-memory task queue. An enqueue acknowledgment is encoded for transmission to the data process responsive to the enqueue request. The task is persisted in a storage location associated with the in-memory task queue. Initiate a lease of the task to a worker node in response to a lease request received from the worker node. A dequeue request is received from the worker node where the dequeue request indicates completion of the task by the worker node. The task is dequeued from the in-memory task queue based on the dequeue request.

公开(公告)号：US20250110718A1

公开(公告)日：2025-04-03

申请号：US18479589

申请日：2023-10-02

Applicant: Snowflake Inc.

Inventor： Jin Mo Ahn ,  Vlad Bunescu ,  Lin Chan ,  Ryan Druckman ,  Adrian Hamza ,  Alexander Hess ,  Gabriel Kliot ,  Albert Nathan McNamara ,  Subramanian Muralidhar ,  Jiaqi Yan

IPC: G06F8/60 ,  G06F11/34

Abstract: A system and method of isolated testing platform for cloud database production queries. The method includes providing an execution platform including a production deployment to receive a first group of queries from a first group of user devices. The production deployment includes a local data storage to store a first dataset associated with the first group of user devices and an execution node to process the first group of queries based on a first version of an application and based on the user data. The method includes receiving a request to test a second version of the application based on the first version of the application. The method includes deploying a ghost deployment onto the execution platform. The method includes replaying the first group of queries on the ghost deployment using copies of the first version of the application and the second version of the application.