Dariusz Górecki
Dariusz Górecki
Thanks, will try to figure it out, the $testObj call is fixed
@nvie I'm using this PoC currently from gevent greenlets, and something on `Job` object like `get_result(timeout=10)` will work with gevent brilliantly. I'm not a fan of callback based concurrency :)
@crearc sending emails when job is done is application logic, and does not belong to RQ, you have 3 options: - Send email from within a job, before returning -...
Yes this is when we connect to cluster using confluent docker containers
I don't know if we can find time to get around to testing that before Easter break, I'll report after the trial run
Here's an error string from my logs: `Error while receiving a message: *Error{Condition: amqp:internal-error, Description: Connection forced: ...` (Shortened output)
After a bit more digging, this in the error returned: https://github.com/Azure/go-amqp/blob/v0.17.0/errors.go#L14 It might be a buggy AMQP1 impl from Rabbit's plugin perspective, but IMO InternalErr from AMQP client shouldn't continue...