Closed sudo-suhas closed 11 months ago
Changes Missing Coverage | Covered Lines | Changed/Added Lines | % | ||
---|---|---|---|---|---|
pkg/worker/pgq/pgq_processor.go | 21 | 27 | 77.78% | ||
internal/workermanager/worker_manager.go | 30 | 51 | 58.82% | ||
<!-- | Total: | 69 | 96 | 71.88% | --> |
Files with Coverage Reduction | New Missed Lines | % | ||
---|---|---|---|---|
internal/workermanager/worker_manager.go | 1 | 70.59% | ||
<!-- | Total: | 1 | --> |
Totals | |
---|---|
Change from base Build 5734607831: | -0.2% |
Covered Lines: | 6161 |
Relevant Lines: | 7058 |
Stats(...)
method toJobProcessor
to allow tracking counts of active and dead jobs by job type.JobProcessor
middleware for OpenTelemetry instrumentation.compass.worker.jobs.enqueue.duration
with the following attributes:job.types
:["index-asset", "delete-asset"]
operation.success
:true
/false
gauge compass.worker.active_jobs
with the following attributes:job.type
:index-asset
/delete-asset
compass.worker.job.dequeue.latency
with the following attributes:job.type
:index-asset
/delete-asset
compass.worker.job.process.duration
with the following attributes:job.type
:index-asset
/delete-asset
job.attempt_number
:1
/2
job.status
:done
/dead
/retry
operation.success
:true
/false
compass.worker.dead_jobs
with the following attributes:job.type
:index-asset
/delete-asset