File tree Expand file tree Collapse file tree 1 file changed +8
-0
lines changed Expand file tree Collapse file tree 1 file changed +8
-0
lines changed Original file line number Diff line number Diff line change 3030 "InterleavedCPUTestServer" ,
3131 "available servers" ,
3232)
33+ flags .DEFINE_integer ("prometheus_port" , 0 , "" )
3334
3435
3536# pylint: disable-next=all
@@ -48,13 +49,20 @@ def main(argv: Sequence[str]):
4849 )
4950 print (f"server_config: { server_config } " )
5051
52+ metrics_server_config : server_lib .MetricsServerConfig | None = None
53+ if FLAGS .prometheus_port != 0 :
54+ metrics_server_config = server_lib .MetricsServerConfig (
55+ port = FLAGS .prometheus_port
56+ )
57+
5158 # We separate credential from run so that we can unit test it with local credentials.
5259 # We would like to add grpc credentials for OSS.
5360 jetstream_server = server_lib .run (
5461 threads = FLAGS .threads ,
5562 port = FLAGS .port ,
5663 config = server_config ,
5764 devices = devices ,
65+ metrics_server_config = metrics_server_config ,
5866 )
5967 print ("Started jetstream_server...." )
6068 jetstream_server .wait_for_termination ()
You can’t perform that action at this time.
0 commit comments