Received: from mail.netlandish.com (mail.netlandish.com [174.136.98.166]) by code.netlandish.com (Postfix) with ESMTP id 1C546A4 for <~netlandish/links-dev@lists.code.netlandish.com>; Mon, 03 Mar 2025 20:03:51 +0000 (UTC) Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=209.85.221.170; helo=mail-vk1-f170.google.com; envelope-from=peter@netlandish.com; receiver= Authentication-Results: mail.netlandish.com; dkim=pass (1024-bit key; unprotected) header.d=netlandish.com header.i=@netlandish.com header.b=E/QaEUB5 Received: from mail-vk1-f170.google.com (mail-vk1-f170.google.com [209.85.221.170]) by mail.netlandish.com (Postfix) with ESMTP id 195BC1D643F for <~netlandish/links-dev@lists.code.netlandish.com>; Mon, 03 Mar 2025 20:03:49 +0000 (UTC) Received: by mail-vk1-f170.google.com with SMTP id 71dfb90a1353d-52364925cfeso2956156e0c.0 for <~netlandish/links-dev@lists.code.netlandish.com>; Mon, 03 Mar 2025 12:03:49 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=netlandish.com; s=google; t=1741032228; x=1741637028; darn=lists.code.netlandish.com; h=content-transfer-encoding:mime-version:message-id:date:subject:cc :to:from:from:to:cc:subject:date:message-id:reply-to; bh=AyRrhf3cgxPjm9tYy/Ed74JcV98faxP0Nalo1StrzoE=; b=E/QaEUB5OlO/PfGHYzsUtDKO78aT1o2V8b4BO6qNnt4gGxsPHANdiSnDQw60Fp3/vu OMZ8EBMZonNSfgqGDu36L1aZK9WeL/zQqW68Isup2lZaqo25i6r4TAHCRJJuJm4o0dsA KoS0lYGa0FJ7qcgPP2UuiXECbCVZ44lArMYZY= X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20230601; t=1741032228; x=1741637028; h=content-transfer-encoding:mime-version:message-id:date:subject:cc :to:from:x-gm-message-state:from:to:cc:subject:date:message-id :reply-to; bh=AyRrhf3cgxPjm9tYy/Ed74JcV98faxP0Nalo1StrzoE=; b=aVumjw2ORajsTI8lcP7NOwYBFhm8rsORaR3Hr1n9ktyV+RUrE34RFGqyJn3vLtZrwi amOMotv4pXCKyn9F6V+qo9yzWfT8oOVofoA5i+qlcjyIAy5lKawKb7QJLEcO7wy1kcrj CeWzUV5dHJy2Ihr05E1j0uebRrb6XZVQkJ6YWWRgHO7c5i6fZ9syfTlslzVjaM4DChn+ 686nGwoqmdfuP5uNPOd7YrVJ5ypv9UstheWSvW9sZLlV2n8K+GRD0oiPRHlzRAdNm+zf Gzf3ivNNSw1G+wF0SbJr+ejHfsnx2j0VHhfhwhGfrkO1BG7th/6iI5sT7xJPjjs74z12 DgAQ== X-Gm-Message-State: AOJu0Yw+rHvAWpzAeK1uyUGkXZKhN37xqTZi3kC8aP0RkVjXdXfL7dDU WuMOY78OuyFvFAxbAh96n/GpWmTaryRvvMYbyAce0D7LH6Nsqm+FLYRFTgtWPKHU7ahEnJjDQJ1 ava8= X-Gm-Gg: ASbGncsQR/cXaGYSwfgu5iDjUOGgbYZm03YA1t2qHVS6AoDPGfi2oXo9x3yP/42nD3y ZkHAgJskkyXHYBCx8MWYJyojn/qbD5Yf5zoVtYM8LhDdwN/XjWtcxjwCLqNzoQsqMO/mFeD9+Xo vGbPfpSvcCLZmqT/aXigW7XFh2VCKOfvVqvs8An1SvgLtk70sg9yhCZcqmG5f/IyWCyKPf3C1gb 1KNB+WPYsfH97nQ0kn/t/KGTlCkWrZRqQNQcQ8spDP2eyJLN9yBtTSBlcRL7PlMn86vxYyTRTTX dFAKPGB+8mmRP2RQKH4hOjDb10Cbk0IKm65ITf8dAo/NsA== X-Google-Smtp-Source: AGHT+IF/Vg8E+PbJ0kH37pJbQ6cqfZH8MvuRlb3+7B0E3P2nFrRW1wRsl01xmHZATLPU9PMWnLZwdg== X-Received: by 2002:a05:6122:370e:b0:50d:39aa:7881 with SMTP id 71dfb90a1353d-523abaa69ebmr798262e0c.0.1741032228506; Mon, 03 Mar 2025 12:03:48 -0800 (PST) Received: from localhost ([2803:2d60:1118:5ee:bbb5:903a:e603:a4e2]) by smtp.gmail.com with ESMTPSA id 71dfb90a1353d-5237c8951absm906435e0c.19.2025.03.03.12.03.47 (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Mon, 03 Mar 2025 12:03:48 -0800 (PST) From: Peter Sanchez To: ~netlandish/links-dev@lists.code.netlandish.com Cc: Peter Sanchez Subject: [PATCH links] No retries on import tasks to avoid import queue being full Date: Mon, 3 Mar 2025 14:03:42 -0600 Message-ID: <20250303200345.7146-1-peter@netlandish.com> X-Mailer: git-send-email 2.47.2 MIME-Version: 1.0 Content-Transfer-Encoding: 8bit --- core/processors.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/processors.go b/core/processors.go index 3f4355c..e6160e6 100644 --- a/core/processors.go +++ b/core/processors.go @@ -65,7 +65,7 @@ func ImportBookmarksTask(c echo.Context, origin int, path string, server.Logger().Printf("Error sending import complete email: %v", err) } return nil - }).Retries(3).Before(func(ctx context.Context, task *work.Task) { + }).Retries(0).Before(func(ctx context.Context, task *work.Task) { gobwebs.TaskIDWork(task) gctx.Server.Logger().Printf( "Running task ImportBookmarksTask %s for the %d attempt.", @@ -90,7 +90,7 @@ func ParseBaseURLTask(srv *server.Server, baseURL *models.BaseURL) *work.Task { ctx = database.Context(ctx, srv.DB) ctx = timezone.Context(ctx, "UTC") return links.ParseBaseURL(ctx, baseURL) - }).Retries(3).Before(func(ctx context.Context, task *work.Task) { + }).Retries(0).Before(func(ctx context.Context, task *work.Task) { gobwebs.TaskIDWork(task) srv.Logger().Printf( "Running task ParseBaseURLTask %s for the %d attempt.", -- 2.47.2