diana/cup
1
0
Fork 0
forked from goffee/cup
Code Pull requests Activity

add maxruns and option for loop forever

Browse source
This commit is contained in:
Jose Cely 2026-06-22 11:46:36 -05:00
parent 3d051e9617
commit a5a9f4ba50
1 changed files with 9 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

18
controllers/schedsample.go
View file

@ -23,40 +23,40 @@ func SchedulerSample(c *core.Context) *core.Response {
ctx := context.Background()
// ── Enqueue a "send_email" task ─────────────────────────────────────────
// ── Enqueue a "send_email" task (runs once, sequential) ────────────────
emailPayload, _ := json.Marshal(map[string]interface{}{
"to": "user@example.com",
"subject": "Hello from the scheduler!",
})
item1, err := store.Enqueue(ctx, "send_email", string(emailPayload), 0)
item1, err := store.Enqueue(ctx, "send_email", string(emailPayload), 0, 1, 0)
if err != nil {
c.GetLogger().Error(fmt.Sprintf("failed to enqueue send_email: %v", err))
return c.Response.SetStatusCode(500).Json(`{"message": "failed to enqueue send_email"}`)
}
c.GetLogger().Info(fmt.Sprintf("[scheduler] enqueued send_email task id=%d", item1.ID))
c.GetLogger().Info(fmt.Sprintf("[scheduler] enqueued send_email task id=%d (maxRuns=1, thread=0)", item1.ID))
// ── Enqueue a "flaky_task" (demonstrates error recording) ───────────────
// ── Enqueue a "flaky_task" (runs 3 times, sequential) ──────────────────
flakyPayload, _ := json.Marshal(map[string]interface{}{
"description": "This task will fail and the error will be recorded",
})
item2, err := store.Enqueue(ctx, "flaky_task", string(flakyPayload), 0)
item2, err := store.Enqueue(ctx, "flaky_task", string(flakyPayload), 0, 3, 0)
if err != nil {
c.GetLogger().Error(fmt.Sprintf("failed to enqueue flaky_task: %v", err))
return c.Response.SetStatusCode(500).Json(`{"message": "failed to enqueue flaky_task"}`)
}
c.GetLogger().Info(fmt.Sprintf("[scheduler] enqueued flaky_task id=%d", item2.ID))
c.GetLogger().Info(fmt.Sprintf("[scheduler] enqueued flaky_task id=%d (maxRuns=3, thread=0)", item2.ID))
// ── Enqueue a high-priority "send_email" task ───────────────────────────
// ── Enqueue a high-priority "send_email" (repeats indefinitely, concurrent) ──
urgentPayload, _ := json.Marshal(map[string]interface{}{
"to": "urgent@example.com",
"subject": "URGENT: Priority message",
})
item3, err := store.Enqueue(ctx, "send_email", string(urgentPayload), 10)
item3, err := store.Enqueue(ctx, "send_email", string(urgentPayload), 10, -1, 1)
if err != nil {
c.GetLogger().Error(fmt.Sprintf("failed to enqueue urgent send_email: %v", err))
return c.Response.SetStatusCode(500).Json(`{"message": "failed to enqueue urgent send_email"}`)
}
c.GetLogger().Info(fmt.Sprintf("[scheduler] enqueued high-priority send_email task id=%d", item3.ID))
c.GetLogger().Info(fmt.Sprintf("[scheduler] enqueued high-priority send_email id=%d (maxRuns=-1/infinite, thread=1/concurrent)", item3.ID))
message := fmt.Sprintf(`{"message": "Enqueued 3 scheduler tasks (send_email x2, flaky_task x1)", "tasks": [%d, %d, %d]}`,
item1.ID, item2.ID, item3.ID)