Nick Dichev

Add generic handlers of distributed trace headers

1

Adds handlers for "generic" (I see this term used elsewhere in this module) `tracestate` and `traceparent` headers for the non-HTTP path of associating a trace. My use case is associating...

Connections being closed -- K8s.Client.Mint.HTTPAdapter Connection closed for reading and writing - stopping this process.

2

Version: 2.5.0 I am having a problem where one of my apps will often (typically ~300-600 times per day) make warning logs that `K8s.Client.Mint.HTTPAdapter Connection closed for reading and writing...

Allow metrics registry to be passed through PrometheusMiddleware

7

Registers the prometheus metrics with a CollectorRegistry as specified by the prometheus-client docs: https://github.com/prometheus/client_python/blob/master/README.md#multiprocess-mode-eg-gunicorn I also notice that the documentation explicitly says to not overwrite `PROMETHEUS_MULTIPROC_DIR` which is being done...

Issue starting worker with PrometheusMiddleware

4

Hi, thanks for the awesome library. I am trying to add the `PrometheusMiddleware` to an application, however, I am seeing some strange behavior when starting the worker(s). `taskiq` version: 0.8.2...

Allow callers to define the scaling strategy of the FLAME pool

2

I've been evaluating FLAME to replace the lambda architecture we are using for one of our services. We are currently using Kubernetes jobs as the runner. We have explicitly chosen...

Runners in a pool which uses the `:single_use` option will terminate after they execute a function call, however, this behavior causes the pool to scale below the configured `:min` value....