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 6767WORKERS_COUNT = Gauge ("de_workers_total" , "Number of workers started by the Decision Engine" )
6868DE_STATUS = Gauge ("de_status" , "Status of Decision Engine server" )
6969
70+
7071class StopState (enum .Enum ):
7172 NotFound = 1
7273 Clean = 2
@@ -944,7 +945,7 @@ def _start_de_server(server):
944945 start_channels_thread .start ()
945946
946947 server .get_logger ().debug ("running _start_de_server: step serve_forever" )
947- DE_STATUS .set (1 )
948+ DE_STATUS .set (1 )
948949 server .serve_forever (
949950 poll_interval = 1
950951 ) # Once per second is sufficient, given the amount of work done in the service actions.
@@ -962,7 +963,7 @@ def _start_de_server(server):
962963 raise __e
963964 finally :
964965 start_channels_thread .join (None )
965- DE_STATUS .set (0 )
966+ DE_STATUS .set (0 )
966967 server .shutdown_complete .wait ()
967968 r = redis .Redis .from_url (server .broker_url )
968969 while _requests_in_flight (r , server .exchange .name ):
You can’t perform that action at this time.
0 commit comments