diff --git a/components/snowflake/package.json b/components/snowflake/package.json
index edc042320cf11..4b85ca566db5e 100644
--- a/components/snowflake/package.json
+++ b/components/snowflake/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/snowflake",
-  "version": "0.9.6",
+  "version": "0.9.7",
   "description": "Pipedream Snowflake Components",
   "main": "snowflake.app.mjs",
   "keywords": [
diff --git a/components/snowflake/sources/change-to-warehouse/change-to-warehouse.mjs b/components/snowflake/sources/change-to-warehouse/change-to-warehouse.mjs
index b892f5cd7de76..9d075b43d14a7 100644
--- a/components/snowflake/sources/change-to-warehouse/change-to-warehouse.mjs
+++ b/components/snowflake/sources/change-to-warehouse/change-to-warehouse.mjs
@@ -17,7 +17,7 @@ export default {
   // eslint-disable-next-line
   name: "New, Updated, or Deleted Warehouse",
   description: "Emit new events when a warehouse is created, altered, or dropped",
-  version: "0.0.10",
+  version: "0.0.11",
   async run() {
     await this.watchObjectsAndEmitChanges("WAREHOUSE", this.warehouses, this.queryTypes);
   },
diff --git a/components/snowflake/sources/common.mjs b/components/snowflake/sources/common.mjs
index 414fbfd5400e9..bf9d119f5725e 100644
--- a/components/snowflake/sources/common.mjs
+++ b/components/snowflake/sources/common.mjs
@@ -21,12 +21,19 @@ export default {
     _setLastMaxTimestamp(lastMaxTimestamp) {
       this.db.set("lastMaxTimestamp", lastMaxTimestamp);
     },
+    async streamToArray(stream) {
+      const result = [];
+      for await (const item of stream) {
+        result.push(item);
+      }
+      return result;
+    },
     async processCollection(statement, timestamp) {
       const rowStream = await this.snowflake.getRows(statement);
-      this.$emit({
-        rows: rowStream,
+      const rows = await this.streamToArray(rowStream);
+      this.$emit(rows, this.generateMetaForCollection({
         timestamp,
-      });
+      }));
     },
     async processSingle(statement, timestamp) {
       let lastResultId;
diff --git a/components/snowflake/sources/failed-task-in-schema/failed-task-in-schema.mjs b/components/snowflake/sources/failed-task-in-schema/failed-task-in-schema.mjs
index 66938729e30af..df552a146f2e6 100644
--- a/components/snowflake/sources/failed-task-in-schema/failed-task-in-schema.mjs
+++ b/components/snowflake/sources/failed-task-in-schema/failed-task-in-schema.mjs
@@ -39,7 +39,7 @@ export default {
   // eslint-disable-next-line
   name: "Failed Task in Schema",
   description: "Emit new events when a task fails in a database schema",
-  version: "0.0.11",
+  version: "0.0.12",
   async run() {
     await this.emitFailedTasks({
       database: this.database,
diff --git a/components/snowflake/sources/new-database/new-database.mjs b/components/snowflake/sources/new-database/new-database.mjs
index 4e85882b49c59..1f301cc730d53 100644
--- a/components/snowflake/sources/new-database/new-database.mjs
+++ b/components/snowflake/sources/new-database/new-database.mjs
@@ -7,7 +7,7 @@ export default {
   key: "snowflake-new-database",
   name: "New Database",
   description: "Emit new event when a database is created",
-  version: "0.0.9",
+  version: "0.0.10",
   methods: {
     ...common.methods,
     alwaysRunInSingleProcessMode() {
diff --git a/components/snowflake/sources/new-role/new-role.mjs b/components/snowflake/sources/new-role/new-role.mjs
index 7670c3452bd8b..1e9c167913de0 100644
--- a/components/snowflake/sources/new-role/new-role.mjs
+++ b/components/snowflake/sources/new-role/new-role.mjs
@@ -6,7 +6,7 @@ export default {
   key: "snowflake-new-role",
   name: "New Role",
   description: "Emit new event when a role is created",
-  version: "0.0.8",
+  version: "0.0.9",
   methods: {
     ...common.methods,
     alwaysRunInSingleProcessMode() {
diff --git a/components/snowflake/sources/new-row/new-row.mjs b/components/snowflake/sources/new-row/new-row.mjs
index 9eb9951a22242..c122251f01dd0 100644
--- a/components/snowflake/sources/new-row/new-row.mjs
+++ b/components/snowflake/sources/new-row/new-row.mjs
@@ -6,7 +6,7 @@ export default {
   key: "snowflake-new-row",
   name: "New Row",
   description: "Emit new event when a row is added to a table",
-  version: "0.1.10",
+  version: "0.1.11",
   methods: {
     ...common.methods,
     async getStatement(lastResultId) {
diff --git a/components/snowflake/sources/new-schema/new-schema.mjs b/components/snowflake/sources/new-schema/new-schema.mjs
index 94e8dd1ca00c7..8b47f6e0a1985 100644
--- a/components/snowflake/sources/new-schema/new-schema.mjs
+++ b/components/snowflake/sources/new-schema/new-schema.mjs
@@ -7,7 +7,7 @@ export default {
   key: "snowflake-new-schema",
   name: "New Schema",
   description: "Emit new event when a schema is created",
-  version: "0.0.9",
+  version: "0.0.10",
   methods: {
     ...common.methods,
     alwaysRunInSingleProcessMode() {
diff --git a/components/snowflake/sources/new-table/new-table.mjs b/components/snowflake/sources/new-table/new-table.mjs
index 796467ca029dc..8e22bf8e515be 100644
--- a/components/snowflake/sources/new-table/new-table.mjs
+++ b/components/snowflake/sources/new-table/new-table.mjs
@@ -7,7 +7,7 @@ export default {
   key: "snowflake-new-table",
   name: "New Table",
   description: "Emit new event when a table is created",
-  version: "0.0.9",
+  version: "0.0.10",
   methods: {
     ...common.methods,
     alwaysRunInSingleProcessMode() {
diff --git a/components/snowflake/sources/new-user/new-user.mjs b/components/snowflake/sources/new-user/new-user.mjs
index e457b935e041d..fdb1a3c1c6fd7 100644
--- a/components/snowflake/sources/new-user/new-user.mjs
+++ b/components/snowflake/sources/new-user/new-user.mjs
@@ -6,7 +6,7 @@ export default {
   key: "snowflake-new-user",
   name: "New User",
   description: "Emit new event when a user is created",
-  version: "0.0.8",
+  version: "0.0.9",
   methods: {
     ...common.methods,
     alwaysRunInSingleProcessMode() {
diff --git a/components/snowflake/sources/query-results/query-results.mjs b/components/snowflake/sources/query-results/query-results.mjs
index 5c5aacbf3b77c..2d754f376e4db 100644
--- a/components/snowflake/sources/query-results/query-results.mjs
+++ b/components/snowflake/sources/query-results/query-results.mjs
@@ -8,7 +8,7 @@ export default {
   name: "New Query Results",
   // eslint-disable-next-line
   description: "Run a SQL query on a schedule, triggering a workflow for each row of results",
-  version: "0.1.10",
+  version: "0.1.11",
   props: {
     ...common.props,
     sqlQuery: {