Skip to content

Commit d64d941

Browse files
authored
Add prometheus_port flag to CLI (#201)
* first commit * config -> flags * config -> flags * fmt
1 parent a12698d commit d64d941

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

jetstream_pt/cli.py

+6
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
flags.DEFINE_integer("max_input_length", 1024, "The batch size")
2828
flags.DEFINE_integer("max_output_length", 1024, "The batch size")
2929
flags.DEFINE_integer("port", 9000, "port to listen on")
30+
flags.DEFINE_integer("prometheus_port", 0, "prometheus metrics port")
3031
flags.DEFINE_integer("threads", 64, "number of worker threads in thread pool")
3132
flags.DEFINE_string(
3233
"benchmark_save_offline_result_to_file",
@@ -104,6 +105,11 @@ def serve():
104105
print(f"server_config: {server_config}")
105106

106107
metrics_server_config: MetricsServerConfig | None = None
108+
if FLAGS.prometheus_port != 0:
109+
if 1 <= FLAGS.prometheus_port <= 65535:
110+
metrics_server_config = MetricsServerConfig(port=FLAGS.prometheus_port)
111+
else:
112+
raise ValueError(f"Invalid port number: {FLAGS.prometheus_port}. Port must be between 1 and 65535.")
107113

108114
# We separate credential from run so that we can unit test it with local credentials.
109115
# We would like to add grpc credentials for OSS.

0 commit comments

Comments
 (0)