Received: from malur.postgresql.org ([217.196.149.56]) by arkaria.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 (Exim 4.94.2) (envelope-from ) id 1taDGS-00HMSm-Ar for pgsql-general@arkaria.postgresql.org; Tue, 21 Jan 2025 12:21:52 +0000 Received: from localhost ([127.0.0.1] helo=malur.postgresql.org) by malur.postgresql.org with esmtp (Exim 4.94.2) (envelope-from ) id 1taDGR-00Fqtw-DE for pgsql-general@arkaria.postgresql.org; Tue, 21 Jan 2025 12:21:51 +0000 Received: from makus.postgresql.org ([2001:4800:3e1:1::229]) by malur.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 (Exim 4.94.2) (envelope-from ) id 1taDGR-00Fqte-32 for pgsql-general@lists.postgresql.org; Tue, 21 Jan 2025 12:21:51 +0000 Received: from mail-oa1-x2b.google.com ([2001:4860:4864:20::2b]) by makus.postgresql.org with esmtps (TLS1.3) tls TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256 (Exim 4.96) (envelope-from ) id 1taDGP-000jEG-0I for pgsql-general@lists.postgresql.org; Tue, 21 Jan 2025 12:21:50 +0000 Received: by mail-oa1-x2b.google.com with SMTP id 586e51a60fabf-2b22c2f5103so548728fac.1 for ; Tue, 21 Jan 2025 04:21:49 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20230601; t=1737462108; x=1738066908; darn=lists.postgresql.org; h=content-transfer-encoding:cc:to:subject:message-id:date:from :in-reply-to:references:mime-version:from:to:cc:subject:date :message-id:reply-to; bh=NTudhZG2HDZ6lj4/Mti0+V74O3lFzbv6WCDHP+5hsk4=; b=SNek0RFH9qLoYbNFW5gOuui7IgDx/gvkh/H2WIp62hmaa4Q7Z3f0vqPw4EQ/LkFW/t 9CPMFroLW2MpVtQTakrXWJ0Go/4IEo7pPb2h4TTqzj56Nx13+XH9BDHvTYMCL8Xg0Poe gypP0scQvxwRYjKZtqcxLj8adxtQobRsG4rQRD1UAytnOGgk4mo9BqSj1AgPO/f67C8a tmmvKJ9t3ohC8jcbfpC/Fm7MrlyzBXSud4UPtL/f8ktXSsuoFzevsnSRYTqkHp9afNzr mviGbBfnSYORlH+RK8iPkHYWS7z2SUdAM8xcjqPaJGy9pKjR81PFzPWXei2/Gwz59yJ4 QL/g== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20230601; t=1737462108; x=1738066908; h=content-transfer-encoding:cc:to:subject:message-id:date:from :in-reply-to:references:mime-version:x-gm-message-state:from:to:cc :subject:date:message-id:reply-to; bh=NTudhZG2HDZ6lj4/Mti0+V74O3lFzbv6WCDHP+5hsk4=; b=h0PT/Bu/hOQnVE5ymwB0q9wBzcpVonIDd/4HW/Jf+zpjkXQ0f+hVWZz2N7WPx2Qe4T lUko73vj8b8ipPBWV3pr6mst0U/W+YA1hs/nF9g6cDLiO3QnK70BjD3c6j5I96ZklGQ/ Y8NMPQ7iwCXgCee+S5fE7ZFXpVkAK0DytFbZtUsBbGMBixQoMlc9HVb1Hs5wZZlekql5 JCoeF0kJo7PIXSzv7GIqnRbeQDhDCx0E8eoLBDZQJx6cgRJbmQXyMKNg4GJ45ER9sPqd 9MGan9dTnZOzuM6gBqF9mCNo84tvRihBcU9z56B+Z7ZJboZRbRixAMlaFfUcMgOC8F3i QT3Q== X-Gm-Message-State: AOJu0YxIpWo4XyOzM1rr4/nGED9MtXPLIB194ORyVLMTiO0O/ImDeRt7 tbYEFvN3fW7QKQ4sS8d5Dqjm8HsrVY8P+6SjQJ5DvOb7t0LRi333dqrwySRjhWFjd5xQgkzu8/j sJpmhhC7VlsqgnAw6WJhI7Zesnqs= X-Gm-Gg: ASbGnctmt86YmDqQtj/wMh9TQkLXKnUKoXi4K3EmNsoynofPJIADwjacq2ahS4bU+Ne H1vHNEIEp6OeNqZQEzX+K2637/Xm/msbKt/c1MJrFfAoLqeuo+rLQGg== X-Google-Smtp-Source: AGHT+IHf2wmO0PEd9EMA6aFPHKwBURb6TscJgJKzLeOdkFj0D+NngKYOMAI9THjAFN8D7OAHccq3mwQId71yt+BeIqc= X-Received: by 2002:a05:6870:45a3:b0:29e:69f7:4c5c with SMTP id 586e51a60fabf-2b1c0a21d4dmr10855703fac.10.1737462108634; Tue, 21 Jan 2025 04:21:48 -0800 (PST) MIME-Version: 1.0 References: In-Reply-To: From: Dominique Devienne Date: Tue, 21 Jan 2025 13:21:36 +0100 X-Gm-Features: AbW1kvYPGGHVn22wzDu68hxXVHa2Yt5mCFSKOqlbtLuYb3bVDGRehNU_t0Svc-Y Message-ID: Subject: Re: Design of a reliable task processing queue To: Alex Burkhart Cc: pgsql-general@lists.postgresql.org Content-Type: text/plain; charset="UTF-8" Content-Transfer-Encoding: quoted-printable List-Id: List-Help: List-Subscribe: List-Post: List-Owner: List-Archive: Archived-At: Precedence: bulk On Sun, Jan 19, 2025 at 9:23=E2=80=AFAM Alex Burkhart wrote: > I'm looking for help to organize locks and transaction for a reliable tas= k queue. Have a look at https://github.com/tembo-io/pgmq for inspiration maybe. --DD