Steven Kreitzer
Steven Kreitzer
@TwiN Done :)
@TwiN Can we get this merged?
I am seeing this as well and it's pretty impactful as it's running steps twice. In the `queue.enqueue` function I set a `on_failure` handler which depending on the exception that...
Roughly less than a minute & this is how I setup a redis connection on the worker: ``` RETRY = Retry(ExponentialBackoff(10, 1), 12) RETRY_ERRORS = [TimeoutError, ConnectionError, ConnectionRefusedError] def get_redis_conn():...
Looks like none are listening. I just replicated the issue in a local development environment and same thing. You can replicate by: 1. create a rq worker 2. shut down...
Thanks @lowercase00, let me know if you need help. I'm debugging on my end too.
> @buroa Have you found some workarounds besides restarting the worker? Apologies. I no longer utilize this project as I left my company where I was using it.
Patiently waiting for this.
> I'm not necessarily against adding the set of k8s HTTP endpoints, but you can use a command to check this already. See #588 and `HEALTCHECK` [in the Dockerfile](https://github.com/0xERR0R/blocky/blob/v0.22/Dockerfile#L79). @ThinkChaos...
> Ok since the body is parsed and I'm currently not sure how to set it this may not be the preferred method. > > I would prefer the method...