公开(公告)号：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.