machinery

machinery copied to clipboard

Finding whether the worker where a task is running is alive or not

3

Also lets say when a worker crashes, due to a non graceful shutdown all the tasks. The tasks in the backend would still be in started state. The asyncResult is...

karthikcru

onsuccess callback function. How to receive parameters? Regarding the callback of success and failure, you can add a demo

Jiang-boyang

Is there an example or some instruction for custom logger with zap?

4

It is complicated to use zap with custom logger since each level of machinery has its own logger, and zap logger set level by method, like `Errorf()` and `Infoln()` I...

chinajuanbob

Hi! I want to update the cron from a registered periodic task dynamically. ``` // create signature periodicCheckingSignature := &machinerytasks.Signature{ Name: taskName, Args: []tasks.Arg{ { Type: "int", Value: item.ID, },...

skykery

Hi, I would like to contribute to the repo for V2. After running ``` go run v2/example/go-redis/main.go ``` the `go.mod` is being modified, the line being added is: ``` github.com/RichardKnop/machinery/v2...

yuming17

Retry

2

When tasks need to retry the configuration in the signature RetryCount/RetryTimeout, task thrown in panic may try again in accordance with the relevant rules, but use "return tasks. NewErrRetryTaskLater ("...

eshine996

Hi Team, I recently started looking into the machinery library to use it in one of my projects. Is it possible to support the `Priority Queue` with machinery? If yes,...

yogesh-desai

Hello everyone, I am using machinery with SQS. One of my tasks takes a long time to finish the process. Most are finish in 30 secs so I use 30...

shun-tak

Issue on multiple workers, task will be duplicated

3

Configured with localhost __redis__ as broker and backend, Register a task with random errors. If i run multiple workers(count>1) in one go process, the retry failure task will be duplicated...

xxxyangyu

Whether V2 / V2 can assign workers for each task.For example, there are 3 tasks. Task A has A maximum of 5 workers, Task B has A maximum of 3...

eshine996