machinery

machinery copied to clipboard

Upgrading required redigo version?

1

Just installed machinery and discovered that it requires: `github.com/gomodule/redigo v2.0.0+incompatible` This old version is causing conflict with some other code. So if I replace it via: `replace github.com/gomodule/redigo => github.com/gomodule/redigo...

armoona

I found a bug in the function of struct redis.Lock in v2/locks/redis/redis.go file. if the key not expired when r.rclient.Get,but expired when r.rclient.GetSet, it will lock failed. My fix codes...

huyidaoxinyu

[current supported task argument type](https://github.com/RichardKnop/machinery#supported-types) ```go // construct custom type codec type Codec interface{ Encode() ([]byte, error) Decode([]byte) error } // register custom type. Reggister("costum type name", codecInstance) ```

gdlxSong

AMQP messages remain ready after being acked

2

I'm running into something unexpected where even after machinery processes and acks messages they are remaining in rabbitmq in a `ready` status. I can observe this by running the example...

willgorman

I'm having issues running a periodic task. I'm setting up the machinery server with a redis backend, then sleeping, and I can submit individual task runs that get picked up...

cameronbarclift

switching task.Headers to use http.Header

7

To make opentracing compatible with opentelemetry, we should be using http Headers. Here's the relevant code in the opentracing shim for opentelemetry: https://github.com/open-telemetry/opentelemetry-go/blob/main/bridge/opentracing/bridge.go#L646 Making this change keeps `machinery` compatible with...

Jarch09

Replace Opentracing with OpenTelemetry on v1

2

Opentracing is no longer the industry standard, and has been replace by Opentelemetry (https://opentelemetry.io/). With this PR, I hope anyone who wish to use Opentelemetry can implement it with ease

abelkuruvilla

fix timeout error when there are too many tasks in a group

akkuman

Unstable network environments in some cases cause amqp to reconnect, or tasks that take too long to execute can cause tasks to be redelivered and may keep re-executing them. we...

akkuman

checkRequiredTablesIfExist() fails with error: 'task table doesn't exist' due to (*dynamodbiface.DynamoDBAPI).ListTables doesn't retrieve full list of tables. You should use for{...}. This PR fixes this bug.

mariiatuzovska