From 4bb34315ebf35c44d5c2369b13b21a4579bb4fb7 Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Sun, 28 Jan 2024 16:32:20 -0500 Subject: [PATCH] feat: add support for tags in RetryableTask --- cron/cron.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/cron/cron.go b/cron/cron.go index 8c9d403..8f0740e 100644 --- a/cron/cron.go +++ b/cron/cron.go @@ -40,6 +40,7 @@ type CronServiceImpl struct { type RetryableTaskParams struct { Name string + Tags []string Function any Args []any Attempt uint @@ -129,11 +130,16 @@ func (c *CronServiceImpl) RetryableTask(params RetryableTaskParams) CronJob { }), gocron.AfterJobRuns(params.After)) name := gocron.WithName(params.Name) + options := []gocron.JobOption{listeners, name} + + if len(params.Tags) > 0 { + options = append(options, gocron.WithTags(params.Tags...)) + } return CronJob{ Job: job, Task: task, - Options: []gocron.JobOption{listeners, name}, + Options: options, } }