mistral.tests.unit.engine package

Subpackages

• mistral.tests.unit.engine.rpc_backend package
  • Subpackages
    • mistral.tests.unit.engine.rpc_backend.kombu package
      • Submodules
      • mistral.tests.unit.engine.rpc_backend.kombu.base module
      • mistral.tests.unit.engine.rpc_backend.kombu.fake_kombu module
      • mistral.tests.unit.engine.rpc_backend.kombu.test_kombu_client module
      • mistral.tests.unit.engine.rpc_backend.kombu.test_kombu_server module
      • Module contents
  • Submodules
  • mistral.tests.unit.engine.rpc_backend.test_rpc module
  • Module contents

Submodules

mistral.tests.unit.engine.base module

class mistral.tests.unit.engine.base.EngineTestCase(*args, **kwds)

Bases: mistral.tests.unit.base.DbTestCase

await_action_error(ex_id, delay=1, timeout=30)

await_action_state(ex_id, state, delay=1, timeout=30)

await_action_success(ex_id, delay=1, timeout=30)

await_task_cancelled(ex_id, delay=1, timeout=30)

await_task_delayed(ex_id, delay=1, timeout=30)

await_task_error(ex_id, delay=1, timeout=30)

await_task_processed(ex_id, delay=1, timeout=30)

await_task_state(ex_id, state, delay=1, timeout=30)

await_task_success(ex_id, delay=1, timeout=30)

await_workflow_cancelled(ex_id, delay=1, timeout=30)

await_workflow_error(ex_id, delay=1, timeout=30)

await_workflow_paused(ex_id, delay=1, timeout=30)

await_workflow_state(ex_id, state, delay=1, timeout=30)

await_workflow_success(ex_id, delay=1, timeout=30)

is_action_error(ex_id)

is_action_in_state(ex_id, state)

is_action_success(ex_id)

is_task_delayed(task_ex_id)

is_task_error(task_ex_id)

is_task_in_state(ex_id, state)

is_task_processed(task_ex_id)

is_task_success(task_ex_id)

is_workflow_in_state(ex_id, state)

kill_threads()

static print_executions(exc_info=None)

setUp()

mistral.tests.unit.engine.test_action_context module

class mistral.tests.unit.engine.test_action_context.ActionContextTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_action_context(*args, **keywargs)

test_single_async_action_context(*args, **keywargs)

test_single_async_saved_action_context(*args, **keywargs)

test_single_sync_action_context(*args, **keywargs)

test_single_sync_saved_action_context(*args, **keywargs)

mistral.tests.unit.engine.test_action_defaults module

class mistral.tests.unit.engine.test_action_defaults.ActionDefaultTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_action_defaults_from_env(*args, **keywargs)

test_action_defaults_from_env_not_applied(*args, **keywargs)

test_with_items_action_defaults_from_env(*args, **keywargs)

test_with_items_action_defaults_from_env_not_applied(*args, **keywargs)

mistral.tests.unit.engine.test_adhoc_actions module

class mistral.tests.unit.engine.test_adhoc_actions.AdhocActionsTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_run_adhoc_action_without_input_value()

test_run_adhoc_action_without_sufficient_input_value()

test_run_workflow_with_adhoc_action()

mistral.tests.unit.engine.test_commands module

class mistral.tests.unit.engine.test_commands.OrderEngineCommandsTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_fail_first()

test_fail_second()

test_succeed_first()

test_succeed_second()

class mistral.tests.unit.engine.test_commands.SimpleEngineCmdsWithMsgTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_fail()

test_pause()

test_succeed()

class mistral.tests.unit.engine.test_commands.SimpleEngineCommandsTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_fail()

test_pause()

test_succeed()

class mistral.tests.unit.engine.test_commands.SimpleEngineWorkflowLevelCmdsWithMsgTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_fail()

test_pause()

test_succeed()

class mistral.tests.unit.engine.test_commands.SimpleEngineWorkflowLevelCommandsTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_fail()

test_pause()

test_succeed()

mistral.tests.unit.engine.test_cron_trigger module

class mistral.tests.unit.engine.test_cron_trigger.ProcessCronTriggerTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_create_cron_trigger_with_pattern_and_first_time(*args, **keywargs)

test_start_workflow(*args, **keywargs)

test_workflow_without_auth()

mistral.tests.unit.engine.test_dataflow module

class mistral.tests.unit.engine.test_dataflow.DataFlowEngineTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_destroy_result()

test_empty_with_items()

test_linear_dataflow()

test_linear_dataflow_implicit_publish()

test_linear_with_branches_dataflow()

test_parallel_tasks()

test_parallel_tasks_complex()

test_sequential_tasks_publishing_same_structured()

test_sequential_tasks_publishing_same_var()

class mistral.tests.unit.engine.test_dataflow.DataFlowTest(*args, **kwds)

Bases: mistral.tests.unit.base.BaseTest

test_context_view()

test_context_view_eval_keys()

test_context_view_eval_root_with_yaql()

test_context_view_eval_values()

test_get_task_execution_result()

mistral.tests.unit.engine.test_default_engine module

class mistral.tests.unit.engine.test_default_engine.DefaultEngineTest(*args, **kwds)

Bases: mistral.tests.unit.base.DbTestCase

setUp()

test_on_action_complete()

test_resume_workflow()

test_start_workflow()

test_start_workflow_env_not_found(*args, **keywargs)

test_start_workflow_missing_parameters()

test_start_workflow_unexpected_parameters()

test_start_workflow_with_adhoc_env()

test_start_workflow_with_env_type_error()

test_start_workflow_with_input_default()

test_start_workflow_with_saved_env(*args, **keywargs)

test_stop_workflow_bad_status()

test_stop_workflow_fail()

test_stop_workflow_succeed()

class mistral.tests.unit.engine.test_default_engine.DefaultEngineWithTransportTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_engine_client_remote_error()

test_engine_client_remote_error_arbitrary()

mistral.tests.unit.engine.test_direct_workflow module

class mistral.tests.unit.engine.test_direct_workflow.DirectWorkflowEngineTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_async_next_task_with_input_yaql_error()

test_async_task_on_clause_has_yaql_error()

test_delete_workflow_completion_check_on_stop()

test_delete_workflow_completion_on_execution_delete()

test_direct_workflow_change_state_after_success()

test_direct_workflow_condition_transition_not_triggering()

test_direct_workflow_on_closures()

test_inconsistent_task_names()

test_messed_yaql_in_first_task()

test_mismatched_yaql_in_first_task()

test_next_task_with_input_yaql_error()

test_one_line_syntax_in_on_clauses()

test_task_on_clause_has_yaql_error()

test_wrong_action()

test_wrong_action_first_task()

test_wrong_first_task_input()

test_wrong_task_input()

mistral.tests.unit.engine.test_direct_workflow_rerun module

class mistral.tests.unit.engine.test_direct_workflow_rerun.DirectWorkflowRerunTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_multiple_reruns_with_items(*args, **keywargs)

test_rerun(*args, **keywargs)

test_rerun_diff_env_vars(*args, **keywargs)

test_rerun_from_prev_step(*args, **keywargs)

test_rerun_join_with_branch_errors(*args, **keywargs)

test_rerun_on_join_task(*args, **keywargs)

test_rerun_subflow(*args, **keywargs)

test_rerun_subflow_task(*args, **keywargs)

test_rerun_with_items(*args, **keywargs)

test_rerun_with_items_concurrency(*args, **kwargs)

test_rerun_with_items_diff_env_vars(*args, **keywargs)

mistral.tests.unit.engine.test_direct_workflow_with_cycles module

class mistral.tests.unit.engine.test_direct_workflow_with_cycles.DirectWorkflowWithCyclesTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_complex_cycle()

test_parallel_cycles()

test_simple_cycle()

mistral.tests.unit.engine.test_environment module

class mistral.tests.unit.engine.test_environment.EnvironmentTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_subworkflow_env_recursive()

test_subworkflow_env_task_input()

mistral.tests.unit.engine.test_error_handling module

class mistral.tests.unit.engine.test_error_handling.ErrorHandlingEngineTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_action_error()

test_action_error_with_wait_after_policy()

test_action_error_with_wait_before_policy()

test_first_task_error()

test_invalid_workflow_input()

test_task_error()

test_task_error_with_on_handlers()

test_workflow_error()

mistral.tests.unit.engine.test_error_result module

class mistral.tests.unit.engine.test_error_result.ErrorResultTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_error_result1()

test_error_result2()

test_success_result()

class mistral.tests.unit.engine.test_error_result.MyAction(success_result, error_result)

Bases: mistral.actions.base.Action

run()

test()

mistral.tests.unit.engine.test_execution_fields_size_limitation module

class mistral.tests.unit.engine.test_execution_fields_size_limitation.ExecutionFieldsSizeLimitTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

Resets the size limit config between tests

tearDown()

Restores the size limit config to default

test_action_input_limit()

test_action_output_limit()

test_default_limit()

test_task_published_limit()

test_workflow_input_default_value_limit()

test_workflow_input_limit()

test_workflow_params_limit()

class mistral.tests.unit.engine.test_execution_fields_size_limitation.MyAction(action_input, action_output_length)

Bases: mistral.actions.base.Action

run()

test()

mistral.tests.unit.engine.test_javascript_action module

class mistral.tests.unit.engine.test_javascript_action.JavaScriptEngineTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_fake_javascript_action_data_context(*args, **keywargs)

test_javascript_action(*args, **kwargs)

mistral.tests.unit.engine.test_join module

class mistral.tests.unit.engine.test_join.JoinEngineTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

delete_join_completion_check_on_execution_delete()

delete_join_completion_check_on_stop()

test_diamond_join_all()

test_discriminator()

test_full_join_parallel_published_vars()

test_full_join_parallel_published_vars_complex(*args, **kwargs)

test_full_join_simple()

test_full_join_with_branch_errors()

test_full_join_with_conditions()

test_full_join_with_errors()

test_full_join_without_errors()

test_join_after_join()

test_join_multiple_routes_with_one_source()

test_join_route_delays()

test_partial_join()

test_partial_join_triggers_once()

mistral.tests.unit.engine.test_noop_task module

class mistral.tests.unit.engine.test_noop_task.NoopTaskEngineTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_noop_task1()

test_noop_task2()

mistral.tests.unit.engine.test_policies module

class mistral.tests.unit.engine.test_policies.PoliciesTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_build_policies()

test_build_policies_with_workflow_defaults()

test_concurrency_is_in_runtime_context()

test_concurrency_is_in_runtime_context_from_var()

test_delayed_task_and_correct_finish_workflow()

test_pause_before_policy()

test_pause_before_with_delay_policy()

test_retry_continue_on(*args, **keywargs)

test_retry_continue_on_not_happened()

test_retry_policy()

test_retry_policy_break_on()

test_retry_policy_break_on_not_happened()

test_retry_policy_from_var()

test_retry_policy_never_happen()

test_retry_policy_one_line()

test_retry_policy_subworkflow_force_fail()

test_retry_policy_succeed_after_failure(*args, **keywargs)

test_task_policy_class()

test_timeout_policy()

test_timeout_policy_from_var()

test_timeout_policy_success_after_timeout()

test_wait_after_policy()

test_wait_after_policy_from_var()

test_wait_before_policy()

test_wait_before_policy_from_var()

test_wait_before_policy_two_tasks()

test_wrong_policy_prop_type()

mistral.tests.unit.engine.test_profiler module

class mistral.tests.unit.engine.test_profiler.EngineProfilerTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_no_profile_trace()

test_profile_trace()

mistral.tests.unit.engine.test_race_condition module

class mistral.tests.unit.engine.test_race_condition.BlockingAction

Bases: mistral.actions.base.Action

run()

test()

static unblock_test()

static wait_for_test()

class mistral.tests.unit.engine.test_race_condition.EngineActionRaceConditionTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

static block_action()

setUp()

test_long_action()

test_short_action(*args, **kwargs)

static unblock_action()

static wait_for_action()

mistral.tests.unit.engine.test_reverse_workflow module

class mistral.tests.unit.engine.test_reverse_workflow.ReverseWorkflowEngineTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_inconsistent_task_names()

test_one_line_requires_syntax()

test_start_task1()

test_start_task2()

mistral.tests.unit.engine.test_reverse_workflow_rerun module

class mistral.tests.unit.engine.test_reverse_workflow_rerun.ReverseWorkflowRerunTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_rerun(*args, **keywargs)

test_rerun_diff_env_vars(*args, **keywargs)

test_rerun_from_prev_step(*args, **keywargs)

mistral.tests.unit.engine.test_run_action module

class mistral.tests.unit.engine.test_run_action.RunActionEngineTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

classmethod heavy_init()

tearDown()

test_adhoc_action_wrong_input()

test_run_action_adhoc()

test_run_action_async()

test_run_action_async_invoke_failure(*args, **keywargs)

test_run_action_async_invoke_with_error(*args, **keywargs)

test_run_action_error(*args, **keywargs)

test_run_action_run_sync()

test_run_action_run_sync_error()

test_run_action_save_result()

test_run_action_save_result_and_run_sync()

test_run_action_sync()

test_run_action_with_kwargs_input(*args, **keywargs)

test_run_action_with_missing_base()

test_run_action_wrong_input()

test_run_level_three_action_adhoc()

test_run_level_two_action_adhoc()

test_run_level_two_loop_action()

test_run_loop_action()

mistral.tests.unit.engine.test_safe_rerun module

class mistral.tests.unit.engine.test_safe_rerun.TestSafeRerun(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_safe_rerun_false(*args, **keywargs)

test_safe_rerun_true(*args, **keywargs)

test_safe_rerun_with_items(*args, **keywargs)

mistral.tests.unit.engine.test_state_info module

class mistral.tests.unit.engine.test_state_info.ExecutionStateInfoTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_state_info()

test_state_info_two_failed_branches()

test_state_info_with_items(*args, **keywargs)

test_state_info_with_policies()

mistral.tests.unit.engine.test_subworkflows module

class mistral.tests.unit.engine.test_subworkflows.SubworkflowsTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_subworkflow_environment_inheritance()

test_subworkflow_error(*args, **keywargs)

test_subworkflow_success()

test_subworkflow_yaql_error()

mistral.tests.unit.engine.test_task_defaults module

class mistral.tests.unit.engine.test_task_defaults.TaskDefaultsDirectWorkflowEngineTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_task_defaults_on_error()

class mistral.tests.unit.engine.test_task_defaults.TaskDefaultsReverseWorkflowEngineTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_task_defaults_requires()

test_task_defaults_retry_policy()

test_task_defaults_timeout_policy()

test_task_defaults_wait_policies()

mistral.tests.unit.engine.test_task_publish module

class mistral.tests.unit.engine.test_task_publish.TaskPublishTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_publish_failure(*args, **keywargs)

mistral.tests.unit.engine.test_with_items module

class mistral.tests.unit.engine.test_with_items.RandomSleepEchoAction(output)

Bases: mistral.actions.base.Action

run()

test()

class mistral.tests.unit.engine.test_with_items.WithItemsEngineTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

assert_capacity(capacity, task_ex)

static get_incomplete_action_ex(task_ex)

static get_running_action_exs_number(task_ex)

test_with_items_action_context()

test_with_items_and_adhoc_action()

test_with_items_concurrency_1(*args, **kwargs)

test_with_items_concurrency_2(*args, **kwargs)

test_with_items_concurrency_2_fail(*args, **kwargs)

test_with_items_concurrency_3(*args, **kwargs)

test_with_items_concurrency_gt_list_length(*args, **kwargs)

test_with_items_concurrency_yaql(*args, **kwargs)

test_with_items_concurrency_yaql_wrong_type(*args, **kwargs)

test_with_items_empty_list()

test_with_items_env()

test_with_items_fail()

test_with_items_multi_array()

test_with_items_plain_list()

test_with_items_plain_list_wrong()

test_with_items_results_one_item_as_list()

test_with_items_results_order()

test_with_items_retry_policy()

test_with_items_retry_policy_concurrency(*args, **kwargs)

test_with_items_simple()

test_with_items_static_var()

test_with_items_sub_workflow_fail()

test_with_items_subflow_concurrency_gt_list_length(*args, **kwargs)

test_with_items_two_tasks_second_starts_on_success()

test_with_items_yaql_fail()

mistral.tests.unit.engine.test_workflow_cancel module

class mistral.tests.unit.engine.test_workflow_cancel.WorkflowCancelTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_cancel_child_workflow()

test_cancel_completed_workflow()

test_cancel_parent_workflow()

test_cancel_paused_workflow()

test_cancel_then_fail_with_items_child_workflow()

test_cancel_with_items_child_workflow()

test_cancel_with_items_parent_workflow()

test_cancel_workflow()

test_fail_then_cancel_with_items_child_workflow()

mistral.tests.unit.engine.test_workflow_resume module

class mistral.tests.unit.engine.test_workflow_resume.WorkflowResumeTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_resume_diff_env_vars()

test_resume_different_task_states()

test_resume_direct()

test_resume_fails()

test_resume_reverse()

test_resume_two_branches()

test_resume_two_start_tasks()

mistral.tests.unit.engine.test_workflow_stop module

class mistral.tests.unit.engine.test_workflow_stop.WorkflowStopTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

setUp()

test_stop_failed()

test_stop_succeeded()

mistral.tests.unit.engine.test_workflow_variables module

class mistral.tests.unit.engine.test_workflow_variables.WorkflowVariablesTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_workflow_variables()

mistral.tests.unit.engine.test_yaql_functions module

class mistral.tests.unit.engine.test_yaql_functions.YAQLFunctionsEngineTest(*args, **kwds)

Bases: mistral.tests.unit.engine.base.EngineTestCase

test_execution_function()

test_task_function()

test_task_function_non_existing()

test_uuid_function()

Module contents