machinery

machinery copied to clipboard

I am suggesting that for the redis broker, the funactionality be switched from using [`BLPOP`](https://github.com/RichardKnop/machinery/blob/master/v2/brokers/redis/goredis.go#L332) and [`RPUSH`](https://github.com/RichardKnop/machinery/blob/master/v2/brokers/redis/goredis.go#L203) for the `Publish` and `nextTask` functions to using `BRPOPLPUSH` and `LPUSH`. The danger...

danthegoodman1

Hi! URIs such as `redis://user1:mypassword@redisinstance/0` do not work as `lock` property in the machinery server config. Specifically the existing code does not handle well the username:password tuple nor the database...

migmartri

SetErrorHandler should support param with signature

5

Just like the source code in exaple： ``` errorhandler := func(err error) { log.ERROR.Println("I am an error handler:", err) } pretaskhandler := func(signature *tasks.Signature) { log.INFO.Println("I am a start of...

Lingerhk

Using string (after json.Marshal ) in TaskResult cause error

1

Backend: mongodb Broker: rabbitmq ``` type TaskParam struct{ ParamType string `json:"param_type"` } func TaskA(args ...string)(string,error){ fmt.Println("in taskA") fmt.Println("out taskA") return args[0],nil } func TaskB(args ...string)(string,error){ fmt.Println("in taskB") fmt.Println("out taskB") return...

xuyue86

add PublishToLocal for health check

1

I need a health check function to check if the local worker can still run properly (e.g. if all the goroutines are stuck and can't start new ones due to...

sljeff

SIGINT is ignored if sent before a worker connects to the broker

9

I'm using redis as my broker and result backend. If I send SIGINT I see a log message saying `Signal received: interrupt. Quitting the worker`, but then the process never...

mbyio

RegisterPeriodicTask repeated execute

1

The program deploys multiple instances with the RegisterPeriodicTask task registered on each instance. At this point, each machine will execute the tasks simultaneously, resulting in repeated execution. For example, the...

lxjian01

Hi, I Add Azure Service bus as a new type of broker, hope this helps someone trap in Azure cloud :P [Azure Service Bus docs](https://docs.microsoft.com/en-us/azure/service-bus-messaging/) for more information.

sgrodriguez

0xKrishna

go get failed because v1.10.5 requires v2.0.4

2

I would install machinery/v1 by below command: ``` go get github.com/RichardKnop/machinery/v1 go get: github.com/RichardKnop/[email protected] updating to github.com/RichardKnop/[email protected] requires github.com/RichardKnop/machinery/[email protected]: reading github.com/RichardKnop/machinery/go.mod at revision v2.0.4: unknown revision v2.0.4 ``` The file...

chowyi