RichardKnop / machinery

Machinery is an asynchronous task queue/job queue based on distributed message passing.
Mozilla Public License 2.0
7.52k stars 914 forks source link

How to bind processing functions for Period Tasks? #791

Open jeefs opened 1 year ago

jeefs commented 1 year ago

err = Server.RegisterPeriodicTask(" * ", "checkIndexTask", CheckIndexTaskSignature()) if err != nil { panic(err.Error()) }

// Get an error report : INFO: 2023/05/09 17:10:34 redis.go:342 Task not registered with this worker. Requeuing message: {"UUID":"task_7da39c38-a78e-4fd4-a4ad-72c85687410d","Name":"checkIndexTask","RoutingKey":"default","ETA": null,"GroupUUID":"","GroupTaskCount":0,"Args":[],"Headers":{},"Priority":0,"Immutable":false,"RetryCount":0,"RetryTimeout":0,"OnSuccess":[],"OnError":[],"ChordCallback":null,"BrokerMessageGroupId":""," SQSReceiptHandle":"","StopTaskDeletionOnError":false,"IgnoreWhenTaskNotRegistered":false}