Hubspot New Deal in Stage - limit initial events

components/hubspot/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/hubspot",
-  "version": "1.7.10",
+  "version": "1.7.11",
   "description": "Pipedream Hubspot Components",
   "main": "hubspot.app.mjs",
   "keywords": [

components/hubspot/sources/new-deal-in-stage/new-deal-in-stage.mjs

@@ -6,12 +6,14 @@ import {
 import common from "../common/common.mjs";
 import sampleEmit from "./test-event.mjs";
 
+const MAX_INITIAL_EVENTS = 25;
+
 export default {
   ...common,
   key: "hubspot-new-deal-in-stage",
   name: "New Deal In Stage",
   description: "Emit new event for each new deal in a stage.",
-  version: "0.0.41",
+  version: "0.1.0",
   dedupe: "unique",
   type: "source",
   props: {
@@ -87,7 +89,7 @@ export default {
         object: "deals",
       };
     },
-    async processDeals(params, after) {
+    async processDeals(params, after, initialEventsEmitted) {
       let maxTs = after || 0;
 
       do {
@@ -111,19 +113,27 @@ export default {
               maxTs = ts;
               this._setAfter(ts);
             }
+            if (!after && ++initialEventsEmitted >= MAX_INITIAL_EVENTS) {
+              return initialEventsEmitted;
+            }
           }
         }
 
         // first run, get only first page
         if (!after) {
-          return;
+          break;
         }
       } while (params.after);
+      return initialEventsEmitted;
     },
     async processResults(after) {
+      let initialEventsEmitted = 0;
       for (const stage of this.stages) {
         const params = this.getStageParams(stage);
-        await this.processDeals(params, after);
+        initialEventsEmitted += await this.processDeals(params, after, initialEventsEmitted);
+        if (initialEventsEmitted >= MAX_INITIAL_EVENTS) {
+          return;
+        }
       }
     },
     getOwner(ownerId) {