chore: wip

Author: chrisbbreuer

app/Jobs/ExampleJob.ts

@@ -5,7 +5,7 @@ import { log } from '@stacksjs/cli'
 export default new Job({
   name: 'Example Job', // optional, defaults to the file name
   description: 'A demo cron job that runs every minute', // optional
-  tries: 3, // optional, defaults to 3, in case of failures
+  tries: 3, // optional, defaults to 3 retries, in case of failures
   backoff: 3, // optional, defaults to 3-second delays between retries
   rate: Every.Minute, // optional, '* * * * *' in cron syntax (overwrites the Scheduler's definition)
   handle: () => { // action: 'SendWelcomeEmail', // instead of handle, you may target an action or `action: () => {`

storage/framework/core/cloud/src/cloud/queue.ts

@@ -36,13 +36,17 @@ export class QueueStack {
           const jobModule = await this.loadJobModule(filePath)
 
           // Now you can safely access jobModule.default.rate
-          const rate = jobModule.default.rate || '* * * * *'
+          const rate = jobModule.default?.rate
+
+          // if no rate or job is disabled, no need to schedule, skip
+          if (!rate || jobModule.default?.enabled === false)
+            continue
 
-          // Rest of your logic here...
           // Convert the rate to a Schedule object
           const schedule = Schedule.cron(this.cronScheduleFromRate(rate))
 
           const id = `QueueRule${pascalCase(file.replace('.ts', ''))}`
+
           // Perform operations with the jobModule.default as needed
           const rule = new Rule(this.scope, id, {
             // schedule to run every second
@@ -69,7 +73,7 @@ export class QueueStack {
               },
             ],
 
-            retryAttempts: 3,
+            retryAttempts: jobModule.default.tries || 3,
 
             subnetSelection: {
               subnetType: ec2.SubnetType.PUBLIC, // SubnetType.PRIVATE_WITH_EGRESS

storage/framework/core/scheduler/src/index.ts

@@ -13,6 +13,7 @@ export type {
   Ranges,
   TimeUnit,
 } from './types/cron'
+export * from './types/utils'
 
 export * from './schedule'
 

storage/framework/core/types/src/cron-jobs.ts

@@ -1,3 +1,5 @@
+import type { IntRange } from '@stacksjs/scheduler'
+
 /**
  * Cron Job Options.
  */
@@ -12,7 +14,10 @@ export interface JobOptions {
   description?: string
   queue?: string
   timezone?: string
-  tries?: number
+  /**
+   * Number of tries. Must be between 0 and 185.
+   */
+  tries?: IntRange<0, 185>
   backoff?: number | number[]
   rate?: string | Every
   enabled?: boolean