chore: bump duty to v1.0.1349 (#3038)

* chore: bump duty to v1.0.1349

* fix: job definition changes

---------

Co-authored-by: moshloop <1489660+moshloop@users.noreply.github.com>
Co-authored-by: Aditya Thebe <contact@adityathebe.com>

Author: 3 people

go.mod

@@ -8,7 +8,7 @@ require (
 	github.com/flanksource/artifacts v1.0.24
 	github.com/flanksource/commons v1.53.1
 	github.com/flanksource/deps v1.0.35 // indirect
-	github.com/flanksource/duty v1.0.1348
+	github.com/flanksource/duty v1.0.1349
 	github.com/flanksource/gomplate/v3 v3.24.84
 	github.com/flanksource/is-healthy v1.0.88
 	github.com/flanksource/kommons v0.31.7

go.sum

@@ -1063,8 +1063,8 @@ github.com/flanksource/commons v1.53.1 h1:WiMvY9XGG//L4ndYKTcmp0NjWXg4B7Wbn4hYWk
 github.com/flanksource/commons v1.53.1/go.mod h1:ZII22jIDJ3fd/Mz7l0SzLFEv8aoSUg+xwfJAAVf8up4=
 github.com/flanksource/deps v1.0.35 h1:tHxhkJSsJBWRmx7lR/X1rI8diz6tu0dsGb7GCROfuIQ=
 github.com/flanksource/deps v1.0.35/go.mod h1:2YRfP32WZrMxGVMYV51RlVHZfgerxf8DT3TqSgjzmTQ=
-github.com/flanksource/duty v1.0.1348 h1:fC1WBpiqlUlpPrgE4C1oEMVMPx4AH8oVJhxLV80yFU0=
-github.com/flanksource/duty v1.0.1348/go.mod h1:sk3nPKqdhu2m5kvlxTx14+gKjj6XJgykyQcGHeZRcKM=
+github.com/flanksource/duty v1.0.1349 h1:wBgwhPAhZm0kZ0rB5/ciUFlVDBIbKw49984SL/+Auo0=
+github.com/flanksource/duty v1.0.1349/go.mod h1:sk3nPKqdhu2m5kvlxTx14+gKjj6XJgykyQcGHeZRcKM=
 github.com/flanksource/gomplate/v3 v3.20.4/go.mod h1:27BNWhzzSjDed1z8YShO6W+z6G9oZXuxfNFGd/iGSdc=
 github.com/flanksource/gomplate/v3 v3.24.84 h1:UOE0yCJsczTIKRaHUvhD6tjCYrbNvOugAizuy0FVlhE=
 github.com/flanksource/gomplate/v3 v3.24.84/go.mod h1:NMMZkFsjbLy/8iY8Fip5N86Y0PP6lZeq+kmPwpVVIL0=

pkg/jobs/canary/sync.go

@@ -176,13 +176,14 @@ func newCanaryJob(c CanaryJob) error {
 		Retention:            job.RetentionBalanced,
 		ResourceID:           c.DBCanary.ID.String(),
 		ResourceType:         "canary",
-		ID:                   fmt.Sprintf("%s/%s", c.Canary.Namespace, c.Canary.Name),
+		Aliases:              []string{fmt.Sprintf("%s/%s", c.Canary.Namespace, c.Canary.Name)},
 		Fn:                   c.Run,
 	}
 
 	if err := j.AddToScheduler(CanaryScheduler); err != nil {
-		return fmt.Errorf("failed to schedule canary %s: %w", j.ID, err)
+		return fmt.Errorf("failed to schedule canary %s (alias: %v): %w", j.ID(), j.Aliases, err)
 	}
+
 	canaryJobs.Store(c.DBCanary.ID.String(), j)
 
 	return nil