Module Import alias Import alias Import alias ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore Str Assign NameStore Str ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Return Num decorator_list FunctionDef arguments args NameParam defaults body Pass decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Dict Str Str decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Return Dict decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Return Dict Str Str decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Return Dict Str Str Str Str Call NameLoad NameLoad Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Dict Str Str decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Dict Str Str decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Return Call NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Return Call NameLoad keyword Str keyword AttributeLoad NameLoad attr keyword Num decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign NameStore Call NameLoad keyword Str keyword NameLoad keyword Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr keyword Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body TryExcept body Assign NameStore Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr NameLoad Assign NameStore Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad handlers ExceptHandler type AttributeLoad NameLoad attr name NameStore body Expr Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr Return NameLoad decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return Set NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad If CompareNotEq NameLoad NameLoad body Assign SubscriptStore NameLoad Index Str BinOpAdd Call AttributeLoad NameLoad attr BinOpMult AttributeLoad NameLoad attr Num Return NameLoad decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr Call NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad Assign NameStore Call NameLoad Assign NameStore Call NameLoad Assign NameStore Dict Assign NameStore BinOpAdd Call AttributeLoad NameLoad attr BinOpMult AttributeLoad NameLoad attr Num Assign NameStore Call NameLoad GeneratorExp TupleLoad NameLoad BinOpAdd NameLoad Call AttributeLoad NameLoad attr comprehension NameStore NameLoad For TupleStore NameStore NameStore AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr If CompareIn NameLoad BinOpSub NameLoad NameLoad body Assign SubscriptStore NameLoad Index NameLoad BinOpAdd BinOpAdd NameLoad BinOpMult AttributeLoad NameLoad attr Num AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr Str If CompareEq NameLoad Str body Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad AugAssignAdd SubscriptStore NameLoad Index NameLoad Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad orelse If CompareEq NameLoad Str body If CompareIn NameLoad NameLoad body Assign SubscriptStore NameLoad Index NameLoad Call AttributeLoad NameLoad attr NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call NameLoad NameLoad Assign NameStore BinOpSub Call NameLoad GeneratorExp NameLoad comprehension TupleStore NameStore NameStore Call AttributeLoad NameLoad attr CompareLt NameLoad NameLoad NameLoad If NameLoad body Expr Call AttributeLoad NameLoad attr Str NameLoad If CompareGtE BinOpBitOr NameLoad NameLoad NameLoad body If NameLoad body Assign NameStore Call NameLoad GeneratorExp NameLoad comprehension NameStore NameLoad CompareNotEq SubscriptLoad NameLoad Index Num Str If NameLoad body Expr Call AttributeLoad NameLoad attr Str NameLoad For NameStore NameLoad body Assign SubscriptStore NameLoad Index NameLoad Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad Break Assign NameStore BinOpSub NameLoad Call NameLoad Call AttributeLoad NameLoad attr If NameLoad body Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad NameLoad attr Call NameLoad GeneratorExp TupleLoad NameLoad Call AttributeLoad NameLoad attr NameLoad comprehension NameStore NameLoad For NameStore Call AttributeLoad NameLoad attr body Assign SubscriptStore NameLoad Index Str NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr Str NameLoad Return Call AttributeLoad NameLoad attr Call NameLoad NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call AttributeLoad NameLoad attr Call NameLoad NameLoad decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Dict For NameStore NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr Str Assign SubscriptStore NameLoad Index NameLoad Call AttributeLoad NameLoad attr NameLoad NameLoad Return NameLoad decorator_list decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword Call NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad NameLoad NameLoad NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr Call NameLoad NameLoad Assign NameStore Call NameLoad GeneratorExp TupleLoad NameLoad SubscriptLoad NameLoad Index Str comprehension TupleStore NameStore NameStore Call AttributeLoad NameLoad attr CompareNotEq SubscriptLoad NameLoad Index Str Str If NameLoad body Raise Call NameLoad BinOpMod Str NameLoad Return NameLoad decorator_list FunctionDef arguments args defaults body Return Call NameLoad decorator_list
N/A N/A multiprocessing N/A time N/A traceback oslo_log log logging shaker.agent agent agent_process shaker.engine.executors base base_executors shaker.engine messaging N/A LOG N/A N/A logging getLogger __name__ N/A HEARTBEAT_AGENT __heartbeat N/A CLEANER_AGENT __cleaner BaseOperation N/A object N/A get_agent_join_timeout N/A N/A self N/A N/A N/A 0 N/A get_active_agent_ids N/A N/A self N/A N/A N/A N/A get_default_reply N/A N/A self agent_id N/A N/A N/A N/A operation none N/A get_reply N/A N/A self agent_id start_at N/A N/A N/A N/A N/A process_reply N/A N/A self agent_id message N/A N/A N/A N/A status ok N/A process_error N/A N/A self agent_id exception N/A N/A N/A N/A status info traceback error N/A str exception N/A N/A traceback format_exc N/A process_failure N/A N/A self agent_id N/A N/A N/A N/A status lost N/A process_interrupt N/A N/A self agent_id N/A N/A N/A N/A status interrupted N/A N/A JoinOperation N/A BaseOperation N/A __init__ N/A N/A self agent_ids polling_interval agent_join_timeout N/A N/A N/A N/A N/A N/A super JoinOperation self __init__ N/A N/A self agent_ids agent_ids N/A N/A self polling_interval polling_interval N/A N/A self agent_join_timeout agent_join_timeout N/A get_agent_join_timeout N/A N/A self N/A N/A N/A N/A self agent_join_timeout N/A get_active_agent_ids N/A N/A self N/A N/A N/A N/A set N/A self agent_ids N/A get_reply N/A N/A self agent_id start_at N/A N/A N/A N/A dict operation configure polling_interval N/A self polling_interval expected_duration 0 N/A N/A ExecuteOperation N/A BaseOperation N/A __init__ N/A N/A self executors N/A N/A N/A N/A N/A N/A super ExecuteOperation self __init__ N/A N/A self executors executors N/A get_active_agent_ids N/A N/A self N/A N/A N/A N/A set N/A N/A N/A self executors keys N/A get_reply N/A N/A self agent_id start_at N/A N/A N/A reply N/A dict operation execute start_at start_at command N/A N/A N/A N/A self executors N/A agent_id get_command expected_duration N/A N/A N/A N/A self executors N/A agent_id get_expected_duration N/A reply N/A process_reply N/A N/A self agent_id message N/A N/A N/A N/A N/A reply N/A N/A N/A N/A self executors N/A agent_id process_reply message N/A r N/A N/A N/A super ExecuteOperation self process_reply agent_id message N/A N/A N/A r update reply N/A N/A N/A N/A base_executors ExecutorException N/A e N/A N/A N/A N/A LOG error Error while processing reply: %s e N/A r N/A N/A N/A super ExecuteOperation self process_error agent_id e N/A N/A N/A r update N/A e record N/A N/A Exception N/A e N/A N/A N/A N/A LOG error Error while processing reply: %s e N/A r N/A N/A N/A super ExecuteOperation self process_error agent_id e N/A r N/A process_failure N/A N/A self agent_id N/A N/A N/A r N/A N/A N/A super ExecuteOperation self process_failure agent_id N/A N/A N/A r update N/A N/A N/A N/A self executors N/A agent_id process_failure N/A r N/A process_interrupt N/A N/A self agent_id N/A N/A N/A r N/A N/A N/A super ExecuteOperation self process_interrupt agent_id N/A N/A N/A r update N/A N/A N/A N/A self executors N/A agent_id process_failure N/A r N/A N/A CleanOperation N/A BaseOperation N/A __init__ N/A N/A self polling_interval N/A N/A N/A N/A self polling_interval polling_interval N/A get_active_agent_ids N/A N/A self N/A N/A N/A N/A CLEANER_AGENT N/A get_default_reply N/A N/A self agent_id N/A N/A N/A reply N/A N/A N/A super CleanOperation self get_default_reply agent_id N/A N/A agent_id HEARTBEAT_AGENT N/A N/A N/A reply N/A start_at N/A N/A N/A time time N/A N/A self polling_interval 4 N/A reply N/A N/A Quorum N/A object N/A __init__ N/A N/A self message_queue polling_interval agent_loss_timeout agent_join_timeout N/A N/A N/A N/A self message_queue message_queue N/A N/A self polling_interval polling_interval N/A N/A self agent_loss_timeout agent_loss_timeout N/A N/A self agent_join_timeout agent_join_timeout N/A __del__ N/A N/A self N/A N/A N/A N/A N/A LOG info Cleaning the quorum N/A N/A N/A self _run N/A CleanOperation N/A self polling_interval N/A _run N/A N/A self operation N/A N/A N/A current N/A N/A operation get_active_agent_ids N/A N/A N/A LOG debug Executing operation %s on agents: %s operation current N/A working N/A set N/A replied N/A set N/A result N/A N/A start_at N/A N/A N/A time time N/A N/A self polling_interval 2 N/A lives N/A dict N/A N/A agent_id N/A start_at N/A N/A operation get_agent_join_timeout N/A agent_id current N/A N/A message reply_handler N/A self message_queue N/A N/A agent_id N/A N/A message get agent_id N/A reply N/A N/A operation get_default_reply agent_id N/A now N/A N/A time time N/A N/A agent_id N/A current replied N/A N/A N/A lives N/A agent_id N/A N/A now N/A N/A self polling_interval 2 N/A self agent_loss_timeout N/A op N/A N/A message get operation N/A N/A op poll N/A N/A reply N/A N/A operation get_reply agent_id start_at N/A N/A lives N/A agent_id N/A N/A reply get expected_duration N/A N/A N/A working add agent_id N/A N/A N/A LOG debug Working agents: %s working N/A N/A N/A op reply N/A N/A N/A agent_id working N/A N/A N/A result N/A agent_id N/A N/A operation process_reply agent_id message N/A N/A N/A replied add agent_id N/A N/A N/A LOG debug Replied agents: %s replied N/A N/A reply_handler reply N/A lost N/A N/A set N/A a N/A N/A a t N/A N/A lives items N/A t now replied N/A lost N/A N/A N/A N/A LOG debug Lost agents: %s lost N/A N/A N/A replied lost current N/A N/A lost N/A N/A filtered N/A set N/A a N/A a lost N/A N/A a N/A 0 _ N/A filtered N/A N/A N/A N/A LOG warning Lost agents: %s filtered N/A agent_id lost N/A N/A N/A result N/A agent_id N/A N/A operation process_failure agent_id N/A N/A N/A LOG info Finished processing operation: %s operation N/A N/A interrupted N/A current N/A set N/A N/A result keys N/A interrupted N/A N/A N/A N/A LOG info Interrupted agents: %s interrupted N/A N/A N/A result update N/A dict N/A N/A a_id N/A N/A operation process_interrupt a_id N/A a_id interrupted N/A record N/A N/A result values N/A N/A N/A record N/A schedule start_at N/A result N/A join N/A N/A self agent_ids N/A N/A N/A N/A N/A LOG info Waiting for quorum of agents: %s agent_ids N/A N/A N/A self _run N/A JoinOperation agent_ids N/A self polling_interval N/A self agent_join_timeout N/A execute N/A N/A self executors N/A N/A N/A N/A N/A self _run N/A ExecuteOperation executors N/A N/A LocalQuorum N/A object N/A execute N/A N/A self executors N/A N/A N/A operation N/A ExecuteOperation executors N/A agent_ids N/A N/A operation get_active_agent_ids N/A result N/A N/A agent_id agent_ids N/A N/A task N/A N/A operation get_reply agent_id None N/A command_res N/A N/A agent_process run_command N/A N/A task get command N/A N/A result N/A agent_id N/A N/A operation process_reply agent_id command_res N/A result N/A N/A make_quorum N/A N/A agent_ids server_endpoint polling_interval agent_loss_timeout agent_join_timeout N/A N/A N/A message_queue N/A N/A messaging MessageQueue server_endpoint N/A heartbeat N/A N/A multiprocessing Process target N/A agent_process work kwargs N/A dict agent_id HEARTBEAT_AGENT endpoint server_endpoint polling_interval polling_interval ignore_sigint True N/A N/A heartbeat daemon True N/A N/A N/A heartbeat start N/A quorum N/A Quorum message_queue polling_interval agent_loss_timeout agent_join_timeout N/A result N/A N/A quorum join N/A set agent_ids N/A failed N/A dict N/A N/A agent_id N/A rec N/A status N/A N/A agent_id rec N/A N/A result items N/A N/A rec N/A status ok N/A failed N/A N/A N/A Exception N/A Agents failed to join: %s failed N/A quorum N/A make_local_quorum N/A N/A N/A N/A N/A N/A LocalQuorum N/A