refactor(orchestrator): replace manual HTTP dispatch with FastAPI
test / integration-docker (pull_request) Failing after 13s
lint / lint (push) Successful in 1m16s
test / image-input-builds (pull_request) Successful in 1m8s
test / unit (pull_request) Successful in 2m43s
test / coverage (pull_request) Has been skipped
tracker-policy-pr / check-pr (pull_request) Failing after 10m11s
test / integration-docker (pull_request) Failing after 13s
lint / lint (push) Successful in 1m16s
test / image-input-builds (pull_request) Successful in 1m8s
test / unit (pull_request) Successful in 2m43s
test / coverage (pull_request) Has been skipped
tracker-policy-pr / check-pr (pull_request) Failing after 10m11s
This commit is contained in:
@@ -62,17 +62,14 @@ def main(argv: list[str] | None = None) -> int:
|
||||
orchestrator = OrchestratorCore(registry, broker, secret)
|
||||
|
||||
server = make_server(orchestrator, host=args.host, port=args.port)
|
||||
bound_host, bound_port = server.server_address[0], server.server_address[1]
|
||||
log.info(
|
||||
"orchestrator control plane listening",
|
||||
context={"host": bound_host, "port": bound_port, "db": str(registry.db_path)},
|
||||
context={"host": args.host, "port": args.port, "db": str(registry.db_path)},
|
||||
)
|
||||
try:
|
||||
server.serve_forever()
|
||||
server.run()
|
||||
except KeyboardInterrupt:
|
||||
log.info("orchestrator shutting down")
|
||||
finally:
|
||||
server.server_close()
|
||||
return 0
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user