Module Import alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias identifier ImportFrom alias Assign NameStore Call AttributeLoad NameLoad attr NameLoad ClassDef bases AttributeLoad NameLoad attr body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad body If CompareIn NameLoad AttributeLoad NameLoad attr body Return NameLoad If CompareNotEq NameLoad NameLoad body Return NameLoad If CompareIs NameLoad NameLoad body Return NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr If CompareNotEq NameLoad NameLoad body Return NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad AttributeLoad AttributeLoad NameLoad attr attr body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr If Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad keyword NameLoad body Return If CompareIn NameLoad AttributeLoad NameLoad attr body Assign NameStore NameLoad If CompareIsNot NameLoad AttributeLoad NameLoad attr body Assign NameStore NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad NameLoad orelse Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad If CompareIsNot NameLoad NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Assign NameStore Dict Str Str Str AttributeLoad NameLoad attr NameLoad NameLoad If CompareIsNot NameLoad AttributeLoad NameLoad attr body Assign SubscriptStore NameLoad Index Str NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad If CompareIsNot NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str TryExcept body Assign NameStore Call AttributeLoad NameLoad attr Str handlers ExceptHandler type NameLoad body Pass orelse TryExcept body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad keyword NameLoad handlers ExceptHandler type NameLoad body Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr keyword Num Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr If Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad orelse Assign NameStore NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body If Call NameLoad NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr keyword NameLoad orelse Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr keyword NameLoad keyword Num decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr keyword Num Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr If Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad orelse Assign NameStore NameLoad Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad NameLoad NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body If Call NameLoad NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr keyword NameLoad orelse Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr keyword Num keyword NameLoad decorator_list decorator_list
N/A N/A functools taskflow.engines.action_engine.actions base taskflow logging taskflow states taskflow task task_atom taskflow.types failure N/A LOG N/A N/A logging getLogger __name__ TaskAction N/A N/A base Action N/A N/A An action that handles scheduling, state changes, ... of task atoms. __init__ N/A N/A self storage notifier task_executor N/A N/A N/A N/A N/A N/A super TaskAction self __init__ storage notifier N/A N/A self _task_executor task_executor N/A _is_identity_transition N/A N/A self old_state state task progress N/A None N/A N/A N/A state N/A self SAVE_RESULT_STATES N/A N/A False N/A N/A state old_state N/A N/A False N/A N/A progress None N/A N/A False N/A old_progress N/A N/A N/A self _storage get_task_progress N/A task name N/A N/A old_progress progress N/A N/A False N/A True N/A change_state N/A N/A self task state progress result N/A None N/A N/A base Action NO_RESULT N/A N/A old_state N/A N/A N/A self _storage get_atom_state N/A task name N/A N/A N/A self _is_identity_transition old_state state task progress progress N/A N/A N/A N/A state N/A self SAVE_RESULT_STATES N/A N/A save_result None N/A N/A result N/A self NO_RESULT N/A N/A save_result result N/A N/A N/A N/A self _storage save N/A task name save_result state N/A N/A N/A N/A N/A self _storage set_atom_state N/A task name state N/A N/A progress None N/A N/A N/A N/A N/A self _storage set_task_progress N/A task name progress N/A task_uuid N/A N/A N/A self _storage get_atom_uuid N/A task name N/A details N/A task_name task_uuid old_state N/A task name task_uuid old_state N/A N/A result N/A self NO_RESULT N/A N/A N/A details N/A result result N/A N/A N/A N/A self _notifier notify state details N/A N/A progress None N/A N/A N/A N/A task update_progress progress N/A _on_update_progress N/A N/A self task event_type details N/A N/A N/A Should be called when task updates its progress. N/A N/A N/A progress N/A N/A details pop progress N/A N/A N/A KeyError N/A N/A N/A N/A N/A N/A N/A N/A N/A self _storage set_task_progress N/A task name progress details details N/A N/A N/A Exception N/A N/A N/A N/A LOG exception Failed setting task progress for %s to %0.3f task progress N/A schedule_execution N/A N/A self task N/A N/A N/A N/A N/A self change_state task N/A states RUNNING progress 0.0 N/A arguments N/A N/A N/A self _storage fetch_mapped_args N/A task rebind atom_name N/A task name optional_args N/A task optional N/A N/A N/A N/A task notifier can_be_registered N/A task_atom EVENT_UPDATE_PROGRESS N/A N/A progress_callback N/A N/A functools partial N/A self _on_update_progress task N/A N/A progress_callback None N/A task_uuid N/A N/A N/A self _storage get_atom_uuid N/A task name N/A N/A N/A N/A self _task_executor execute_task task task_uuid arguments progress_callback progress_callback N/A complete_execution N/A N/A self task result N/A N/A N/A N/A isinstance result N/A failure Failure N/A N/A N/A N/A self change_state task N/A states FAILURE result result N/A N/A N/A N/A self change_state task N/A states SUCCESS result result progress 1.0 N/A schedule_reversion N/A N/A self task N/A N/A N/A N/A N/A self change_state task N/A states REVERTING progress 0.0 N/A arguments N/A N/A N/A self _storage fetch_mapped_args N/A task revert_rebind atom_name N/A task name optional_args N/A task revert_optional N/A task_uuid N/A N/A N/A self _storage get_atom_uuid N/A task name N/A task_result N/A N/A N/A self _storage get N/A task name N/A failures N/A N/A N/A self _storage get_failures N/A N/A N/A N/A task notifier can_be_registered N/A task_atom EVENT_UPDATE_PROGRESS N/A N/A progress_callback N/A N/A functools partial N/A self _on_update_progress task N/A N/A progress_callback None N/A N/A N/A N/A self _task_executor revert_task task task_uuid arguments task_result failures progress_callback progress_callback N/A complete_reversion N/A N/A self task result N/A N/A N/A N/A isinstance result N/A failure Failure N/A N/A N/A N/A self change_state task N/A states REVERT_FAILURE result result N/A N/A N/A N/A self change_state task N/A states REVERTED progress 1.0 result result N/A N/A