File tree Expand file tree Collapse file tree
src/decisionengine/framework/engine Expand file tree Collapse file tree Original file line number Diff line number Diff line change 6565QUERY_TOOL_HISTOGRAM = Histogram ("de_client_query_duration_seconds" , "Time to run de-client --query" , ["product" ])
6666METRICS_HISTOGRAM = Histogram ("de_client_metrics_duration_seconds" , "Time to run de-client --status" )
6767WORKERS_COUNT = Gauge ("de_workers_total" , "Number of workers started by the Decision Engine" )
68-
68+ DE_STATUS = Gauge ( "de_status" , "Status of Decision Engine server" )
6969
7070class StopState (enum .Enum ):
7171 NotFound = 1
@@ -944,6 +944,7 @@ def _start_de_server(server):
944944 start_channels_thread .start ()
945945
946946 server .get_logger ().debug ("running _start_de_server: step serve_forever" )
947+ DE_STATUS .set (1 )
947948 server .serve_forever (
948949 poll_interval = 1
949950 ) # Once per second is sufficient, given the amount of work done in the service actions.
@@ -961,6 +962,7 @@ def _start_de_server(server):
961962 raise __e
962963 finally :
963964 start_channels_thread .join (None )
965+ DE_STATUS .set (0 )
964966 server .shutdown_complete .wait ()
965967 r = redis .Redis .from_url (server .broker_url )
966968 while _requests_in_flight (r , server .exchange .name ):
You can’t perform that action at this time.
0 commit comments