Supabase: Select Row sometimes returns errors (#17057)

michelle0927 · web-flow · commit f1eb5a39ba18 · 2025-06-12T16:44:57.000-04:00
* add retry

* pnpm-lock.yaml

* versions

* updates

* update
diff --git a/components/supabase/actions/batch-insert-rows/batch-insert-rows.mjs b/components/supabase/actions/batch-insert-rows/batch-insert-rows.mjs
@@ -6,7 +6,7 @@ export default {
   key: "supabase-batch-insert-rows",
   name: "Batch Insert Rows",
   description: "Inserts new rows into a database. [See the documentation](https://supabase.com/docs/reference/javascript/insert)",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     supabase,
diff --git a/components/supabase/actions/delete-row/delete-row.mjs b/components/supabase/actions/delete-row/delete-row.mjs
@@ -4,7 +4,7 @@ export default {
   key: "supabase-delete-row",
   name: "Delete Row",
   type: "action",
-  version: "0.1.2",
+  version: "0.1.3",
   description: "Deletes row(s) in a database. [See the docs here](https://supabase.com/docs/reference/javascript/delete)",
   props: {
     supabase,
diff --git a/components/supabase/actions/insert-row/insert-row.mjs b/components/supabase/actions/insert-row/insert-row.mjs
@@ -4,7 +4,7 @@ export default {
   key: "supabase-insert-row",
   name: "Insert Row",
   type: "action",
-  version: "0.1.2",
+  version: "0.1.3",
   description: "Inserts a new row into a database. [See the docs here](https://supabase.com/docs/reference/javascript/insert)",
   props: {
     supabase,
diff --git a/components/supabase/actions/remote-procedure-call/remote-procedure-call.mjs b/components/supabase/actions/remote-procedure-call/remote-procedure-call.mjs
@@ -4,7 +4,7 @@ export default {
   key: "supabase-remote-procedure-call",
   name: "Remote Procedure Call",
   type: "action",
-  version: "0.1.2",
+  version: "0.1.3",
   description: "Call a Postgres function in a database. [See the docs here](https://supabase.com/docs/reference/javascript/rpc)",
   props: {
     supabase,
diff --git a/components/supabase/actions/select-row/select-row.mjs b/components/supabase/actions/select-row/select-row.mjs
@@ -5,7 +5,7 @@ export default {
   key: "supabase-select-row",
   name: "Select Row",
   type: "action",
-  version: "0.1.2",
+  version: "0.1.3",
   description: "Selects row(s) in a database. [See the docs here](https://supabase.com/docs/reference/javascript/select)",
   props: {
     supabase,
@@ -81,7 +81,7 @@ export default {
       sortOrder,
       max,
     });
-    $.export("$summary", `Successfully retrieved ${response.length} rows from table ${table}`);
+    $.export("$summary", `Successfully retrieved ${response.data?.length || 0} row(s) from table ${table}`);
     return response;
   },
 };
diff --git a/components/supabase/actions/update-row/update-row.mjs b/components/supabase/actions/update-row/update-row.mjs
@@ -4,7 +4,7 @@ export default {
   key: "supabase-update-row",
   name: "Update Row",
   type: "action",
-  version: "0.1.2",
+  version: "0.1.3",
   description: "Updates row(s) in a database. [See the docs here](https://supabase.com/docs/reference/javascript/update)",
   props: {
     supabase,
diff --git a/components/supabase/actions/upsert-row/upsert-row.mjs b/components/supabase/actions/upsert-row/upsert-row.mjs
@@ -4,7 +4,7 @@ export default {
   key: "supabase-upsert-row",
   name: "Upsert Row",
   type: "action",
-  version: "0.1.2",
+  version: "0.1.3",
   description: "Updates a row in a database or inserts new row if not found. [See the docs here](https://supabase.com/docs/reference/javascript/upsert)",
   props: {
     supabase,
diff --git a/components/supabase/package.json b/components/supabase/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/supabase",
-  "version": "0.3.0",
+  "version": "0.3.1",
   "description": "Pipedream Supabase Components",
   "main": "supabase.app.mjs",
   "keywords": [
diff --git a/components/supabase/sources/new-row-added/new-row-added.mjs b/components/supabase/sources/new-row-added/new-row-added.mjs
@@ -9,7 +9,7 @@ export default {
   key: "supabase-new-row-added",
   name: "New Row Added",
   description: "Emit new event for every new row added in a table. [See documentation here](https://supabase.com/docs/reference/javascript/select)",
-  version: "0.0.4",
+  version: "0.0.5",
   type: "source",
   props: {
     ...base.props,
diff --git a/components/supabase/sources/new-webhook-event/new-webhook-event.mjs b/components/supabase/sources/new-webhook-event/new-webhook-event.mjs
@@ -5,7 +5,7 @@ export default {
   key: "supabase-new-webhook-event",
   name: "New Webhook Event (Instant)",
   description: "Emit new event for every `insert`, `update`, or `delete` operation in a table. This source requires user configuration using the Supabase website. More information in the README. [Also see documentation here](https://supabase.com/docs/guides/database/webhooks#creating-a-webhook)",
-  version: "0.0.5",
+  version: "0.0.6",
   type: "source",
   props: {
     ...base.props,
diff --git a/components/supabase/supabase.app.mjs b/components/supabase/supabase.app.mjs
@@ -52,6 +52,30 @@ export default {
     async _client() {
       return createClient(`https://${this.$auth.subdomain}.supabase.co`, this.$auth.service_key);
     },
+    retryWithExponentialBackoff(func, maxAttempts = 3, baseDelayS = 2) {
+      let attempt = 0;
+      const verifyForErrors = this.verifyForErrors;
+
+      const execute = async () => {
+        try {
+          const resp = await func();
+          verifyForErrors(resp);
+          return resp;
+        } catch (error) {
+          if (attempt === maxAttempts - 1) {
+            throw error;
+          }
+
+          const delayMs = Math.pow(baseDelayS, attempt) * 1000;
+          await new Promise((resolve) => setTimeout(resolve, delayMs));
+
+          attempt++;
+          return execute();
+        }
+      };
+
+      return execute();
+    },
     async selectRow(args) {
       const client = await this._client();
       const {
@@ -63,13 +87,14 @@ export default {
         ascending = args.sortOrder === "ascending",
         max,
       } = args;
-      const query = this.baseFilter(client, table, orderBy, ascending, max);
-      if (filter) {
-        const filterMethod = this[filter];
-        filterMethod(query, column, value);
-      }
-      const resp = await query;
-      this.verifyForErrors(resp);
+      const ctx = this;
+      const resp = await this.retryWithExponentialBackoff(async () => {
+        let query = ctx.baseFilter(client, table, orderBy, ascending, max);
+        if (filter) {
+          query = ctx[filter](query, column, value);
+        }
+        return await query;
+      });
       return resp;
     },
     baseFilter(client, table, orderBy, ascending, max) {

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@pipedream/supabase",`
`3`		`- "version": "0.3.0",`
	`3`	`+ "version": "0.3.1",`
`4`	`4`	`"description": "Pipedream Supabase Components",`
`5`	`5`	`"main": "supabase.app.mjs",`
`6`	`6`	`"keywords": [`