mistral.tests.unit.engine package

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_output_on_error_wb_yaql_failed()
test_parallel_tasks()
test_parallel_tasks_complex()
test_publish_on_error()
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(*args, **keywargs)
test_resume_workflow(*args, **keywargs)
test_start_workflow(*args, **keywargs)
test_start_workflow_env_not_found(*args, **keywargs)
test_start_workflow_missing_parameters(*args, **keywargs)
test_start_workflow_unexpected_parameters(*args, **keywargs)
test_start_workflow_with_adhoc_env(*args, **keywargs)
test_start_workflow_with_env_type_error(*args, **keywargs)
test_start_workflow_with_input_default(*args, **keywargs)
test_start_workflow_with_saved_env(*args, **keywargs)
test_stop_workflow_bad_status(*args, **keywargs)
test_stop_workflow_fail(*args, **keywargs)
test_stop_workflow_succeed(*args, **keywargs)
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_direct_workfow_output()
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_rerun_cancelled module

class mistral.tests.unit.engine.test_direct_workflow_rerun_cancelled.DirectWorkflowRerunCancelledTest(*args, **kwds)

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

test_rerun_cancelled_subflow(*args, **keywargs)
test_rerun_cancelled_subflow_task(*args, **keywargs)
test_rerun_cancelled_task(*args, **keywargs)
test_rerun_cancelled_with_items(*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_error_message_format_complete_task()
test_error_message_format_invalid_on_task_run()
test_error_message_format_key_error()
test_error_message_format_on_action_complete()
test_error_message_format_on_adhoc_action_error()
test_error_message_format_on_task_continue()
test_error_message_format_unknown_function()
test_first_task_error()
test_invalid_action_result()
test_invalid_task_input()
test_invalid_workflow_input()
test_publish_bad_jinja()
test_publish_bad_yaql()
test_task_error()
test_task_error_with_on_handlers()
test_workflow_error()
class mistral.tests.unit.engine.test_error_handling.InvalidUnicodeAction

Bases: mistral.actions.base.Action

run()
test()

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

test_delete_join_completion_check_on_execution_delete()
test_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_join_with_deep_dependencies_tree()
test_no_workflow_error_after_inbound_error()
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(*args, **keywargs)
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_retry_policy_succeed_after_failure_with_publish(*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_reverse_workflow_rerun_cancelled module

class mistral.tests.unit.engine.test_reverse_workflow_rerun_cancelled.ReverseWorkflowRerunCancelledTest(*args, **kwds)

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

test_rerun_cancelled_task(*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_cancel module

class mistral.tests.unit.engine.test_task_cancel.TaskCancelTest(*args, **kwds)

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

test_cancel_action_execution()
test_cancel_action_execution_with_task_retry()
test_cancel_child_workflow_action_execution()
test_cancel_with_items_concurrency(*args, **kwargs)

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(*args, **keywargs)
class mistral.tests.unit.engine.test_task_defaults.TaskDefaultsReverseWorkflowEngineTest(*args, **kwds)

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

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_tasks_function module

class mistral.tests.unit.engine.test_tasks_function.TasksFunctionTest(*args, **kwds)

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

setUp()
test_tasks_function()

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

test_with_items_action_context()
test_with_items_and_adhoc_action(*args, **keywargs)
test_with_items_concurrency_1()
test_with_items_concurrency_2()
test_with_items_concurrency_2_fail()
test_with_items_concurrency_3()
test_with_items_concurrency_gt_list_length()
test_with_items_concurrency_retry_policy()
test_with_items_concurrency_yaql()
test_with_items_concurrency_yaql_wrong_type()
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_simple()
test_with_items_static_var()
test_with_items_sub_workflow_fail()
test_with_items_subflow_concurrency_gt_list_length()
test_with_items_two_tasks_second_starts_on_success()
test_with_items_yaql_fail()

mistral.tests.unit.engine.test_with_items_task module

class mistral.tests.unit.engine.test_with_items_task.WithItemsTaskTest(*args, **kwds)

Bases: mistral.tests.unit.base.BaseTest

static get_action_ex(accepted, state, index)
test_get_next_indices()

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_no_arguments()
test_task_function_non_existing()
test_task_function_returns_null()
test_uuid_function()

Module contents