machinery icon indicating copy to clipboard operation
machinery copied to clipboard

Machinery is an asynchronous task queue/job queue based on distributed message passing.

Results 143 machinery issues
Sort by recently updated
recently updated
newest added

Current error handler only accept error as arguments, I propose to add failed task signature to make it more useful. Some use case is when we need to broadcast error...

After using RegisterPeriodicTask to register a periodic task, there is no way to cancel it. There is an EntryID when registering the task, but it is not returned to the...

I hate to be that guy, but is there intention to continue maintaining this project or is there an actively maintained fork?

Does Machinery V1 support Redis V6 and up which requires TLS connection (rediss://)? If yes, how to set the config so InsecureSkipVerify parameter could be set to true

Currently PeriodicTask use `standardParser` for schedule, wihch only support to minute, it is useful to support custom cron parser

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...

I got an error while I tring to compile my project with machinery/v1 Here is the log: ``` external/com_google_cloud_go_pubsub/message.go:42:42: impossible type assertion: *psAckHandler does not implement "cloud.google.com/go/internal/pubsub".AckHandler (missing OnAckWithResult method)...

- Because the results_expire_in parameter is set, the task result is lost before the task is executed. As a result, the scheduled task is lost. - Whether results_expire_in is supported...

Hello! I have found that your jobs library is actively developed and support different backends which are good. But I haven't found any possibility to run jobs in batches. Case:...