44
44
45
45
LOG = logging .getLogger (__name__ )
46
46
47
- # If an ActionExecutionSchedulingQueueItemDB object hasn't been updated fore more than this amount
48
- # of milliseconds, it will be marked as "handled=False".
49
- # As soon as an item is picked by scheduler to be processed, it should be processed very fast
50
- # (< 5 seconds). If an item is still being marked as processing it likely indicates that the
51
- # scheduler process which was processing that item crashed or similar so we need to mark it as
52
- # "handling=False" so some other scheduler process can pick it up.
53
-
54
47
# When a policy delayed execution is detected it will be try to be rescheduled by the scheduler
55
48
# again in this amount of milliseconds.
56
49
POLICY_DELAYED_EXECUTION_RESCHEDULE_TIME_MS = 2500
@@ -61,6 +54,12 @@ def __init__(self):
61
54
self .message_type = LiveActionDB
62
55
self ._shutdown = False
63
56
self ._pool = eventlet .GreenPool (size = cfg .CONF .scheduler .pool_size )
57
+ # If an ActionExecutionSchedulingQueueItemDB object hasn't been updated fore more than this amount
58
+ # of milliseconds, it will be marked as "handled=False".
59
+ # As soon as an item is picked by scheduler to be processed, it should be processed very fast
60
+ # (< 5 seconds). If an item is still being marked as processing it likely indicates that the
61
+ # scheduler process which was processing that item crashed or similar so we need to mark it as
62
+ # "handling=False" so some other scheduler process can pick it up.
64
63
self ._execution_scheduling_timeout_threshold_ms = \
65
64
cfg .CONF .scheduler .execution_scheduling_timeout_threshold_min \
66
65
* 60 * 1000
0 commit comments