added throttle by defer

Author: ackava

src/workflows/WorkflowContext.ts

@@ -227,16 +227,19 @@ export default class WorkflowContext {
         let throttleGroup = null;
 
         if (throttle) {
-            const { deferSeconds } = throttle;
+            const { deferSeconds, group } = throttle;
             if (deferSeconds) {
                 const lw = await this.storage.getLastEta(throttle);
                 if (lw) {
                     return lw.id;
                 }
+                eta = DateTime.now.addSeconds(deferSeconds);
+                queued = eta;
+                throttleGroup = group;
             } else {
                 eta = await this.storage.getNextEta(throttle);
                 queued = eta;
-                throttleGroup = throttle.group;
+                throttleGroup = group;
             }
         }
 

src/workflows/WorkflowStorage.ts

@@ -12,11 +12,18 @@ import Sql from "../sql/Sql.js";
 
 export type IWorkflowThrottleGroup = {
     group: string;
+    /**
+     * Throttling based on defer, the workflow will be scheduled in future
+     * only if current workflow in same throttle group is queued or running.
+     */
     deferSeconds?: number;
     maxPerSecond?: never;
 } | {
     group: string;
     deferSeconds?: never;
+    /**
+     * Throttled on based on maximum iterations per second.
+     */
     maxPerSecond?: number;
 };