Module ImportFrom alias ImportFrom alias Import alias Import alias Import alias Import alias ImportFrom alias ImportFrom alias Import alias Import alias Import alias ImportFrom alias alias alias alias ImportFrom alias ImportFrom alias Import alias Assign NameStore Call NameLoad FunctionDef arguments args NameParam NameParam defaults body Assign NameStore BinOpMod Str TupleLoad Call AttributeLoad Str attr NameLoad Call AttributeLoad NameLoad attr With Call NameLoad NameLoad Str NameStore body Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list Call AttributeLoad NameLoad attr Str FunctionDef arguments args NameParam defaults body With Call NameLoad NameLoad NameStore body Return Call AttributeLoad NameLoad attr NameLoad decorator_list Call AttributeLoad NameLoad attr Str FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr BinOpMod Str NameLoad keyword NameLoad Print NameLoad decorator_list Call AttributeLoad NameLoad attr Str FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr NameLoad keyword NameLoad Print NameLoad decorator_list Call AttributeLoad NameLoad attr Str Assign NameStore Call NameLoad keyword AttributeLoad NameLoad attr keyword Dict Str Dict Str Str Num Num Expr Call AttributeLoad NameLoad attr FunctionDef arguments args defaults body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr decorator_list Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list Call AttributeLoad NameLoad attr keyword Str FunctionDef arguments args NameParam defaults body FunctionDef arguments args NameParam defaults body Assign TupleStore NameStore NameStore Call AttributeLoad NameLoad attr NameLoad Str Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad Return TupleLoad NameLoad NameLoad decorator_list Expr Yield NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str NameLoad If BoolOpOr UnaryOpNot NameLoad UnaryOpNot NameLoad body Return If UnaryOpNot Call NameLoad NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr Str Str NameLoad Str NameLoad Str Str keyword Str keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr Str decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad NameLoad body Assign NameStore Call AttributeLoad NameLoad attr Str keyword AttributeLoad NameLoad attr keyword Call NameLoad keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr Str For NameStore Call AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword Dict Str Str NameLoad NameLoad keyword NameLoad body For NameStore SubscriptLoad NameLoad Index Str body If BoolOpAnd NameLoad Call AttributeLoad SubscriptLoad NameLoad Index Str attr Str body Continue Expr Yield NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr Str Str BinOpMod Str TupleLoad NameLoad NameLoad keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr Call AttributeLoad Str attr ListComp NameLoad comprehension NameStore NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call NameLoad NameLoad NameLoad Return CompareEq SubscriptLoad SubscriptLoad NameLoad Index Str Index Str Str decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call NameLoad NameLoad NameLoad If CompareNotEq SubscriptLoad SubscriptLoad NameLoad Index Str Index Str Str body Return NameLoad orelse Return SubscriptLoad SubscriptLoad NameLoad Index Str Index Str decorator_list FunctionDef arguments args NameParam NameParam defaults body With Call NameLoad Str NameStore body With Call NameLoad Str body With Call NameLoad Str body Expr Call NameLoad keyword Str keyword Str Expr Call NameLoad keyword Str keyword Str Expr Call NameLoad keyword Str keyword Str Assign TupleStore NameStore NameStore Call NameLoad NameLoad While UnaryOpNot Call NameLoad NameLoad NameLoad body Print Str Expr Call AttributeLoad NameLoad attr Num Assert CompareEq Call NameLoad NameLoad NameLoad Str decorator_list FunctionDef arguments args NameParam NameParam defaults body With Call NameLoad Str NameStore body With Call NameLoad Str body Expr Call NameLoad keyword Str keyword Str Assign TupleStore NameStore NameStore Call NameLoad NameLoad While UnaryOpNot Call NameLoad NameLoad NameLoad body Print Str Expr Call AttributeLoad NameLoad attr Num Assert CompareEq Call NameLoad NameLoad NameLoad Str For NameStore Call NameLoad NameLoad NameLoad keyword NameLoad body Assert CompareEq SubscriptLoad NameLoad Index Str Str Assign NameStore SubscriptLoad NameLoad Index Str Assert CompareIn Str SubscriptLoad NameLoad Index Str Break decorator_list FunctionDef arguments args NameParam NameParam defaults body With Call NameLoad Str keyword NameLoad NameStore body With Call NameLoad Str body Expr Call NameLoad keyword Str keyword Str With Call NameLoad Str body Expr Call NameLoad keyword Str keyword Str Assign TupleStore NameStore NameStore Call NameLoad NameLoad While UnaryOpNot Call NameLoad NameLoad NameLoad body Print Str Expr Call AttributeLoad NameLoad attr Num Assert CompareEq Call NameLoad NameLoad NameLoad Str Assign NameStore Call NameLoad For NameStore Call NameLoad NameLoad NameLoad body If CompareNotEq SubscriptLoad NameLoad Index Str Str body Continue Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Str Index Str Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Str Index Str Assert CompareEq Call NameLoad NameLoad NameLoad Str Expr Call AttributeLoad NameLoad attr Call AttributeLoad Str attr SubscriptLoad Call AttributeLoad NameLoad attr Str Slice Num Assert CompareEq NameLoad Call NameLoad ListLoad Str Str Assign NameStore ListLoad Assign NameStore Dict For NameStore Call NameLoad NameLoad NameLoad body If CompareNotEq SubscriptLoad NameLoad Index Str Str body Continue Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Str Index Str Assign NameStore Call AttributeLoad Str attr SubscriptLoad Call AttributeLoad NameLoad attr Str Slice Num Assign SubscriptStore NameLoad Index NameLoad Call AttributeLoad NameLoad attr SubscriptLoad NameLoad Index Str Assert CompareLt Call NameLoad BinOpSub SubscriptLoad NameLoad Index Str SubscriptLoad NameLoad Index Str Call NameLoad keyword Num decorator_list FunctionDef arguments args NameParam NameParam defaults body With Call NameLoad Str NameStore body With Call NameLoad keyword Str body Expr Call NameLoad keyword Str keyword Str Expr Call NameLoad keyword Str keyword Str keyword NameLoad Assign TupleStore NameStore NameStore Call NameLoad NameLoad While UnaryOpNot Call NameLoad NameLoad NameLoad body Print Str Expr Call AttributeLoad NameLoad attr Num Assert CompareEq Call NameLoad NameLoad NameLoad Str decorator_list
N/A datetime timedelta multiprocessing Process N/A json N/A os N/A subprocess N/A time botocore.client Config sh aws N/A arrow N/A boto3 N/A pytest mass Job Task Action InputHandler mass.scheduler.swf config mass.scheduler.swf SWFWorker N/A mass N/A input_handler N/A InputHandler save_to_local N/A N/A data genealogy N/A N/A N/A file_path N/A /tmp/%s__%d.job N/A N/A N/A __ join genealogy N/A N/A time time N/A N/A open file_path w f N/A N/A N/A N/A f write N/A N/A json dumps data N/A file_path N/A N/A N/A input_handler saver local load_from_local N/A N/A file_path N/A N/A N/A N/A open file_path fp N/A N/A N/A N/A json load fp N/A N/A N/A input_handler loader local worker N/A N/A request N/A N/A N/A worker N/A SWFWorker echo N/A N/A msg N/A N/A N/A output N/A N/A subprocess check_output N/A echo %s msg shell True N/A output N/A N/A N/A worker role echo run N/A N/A cmd N/A N/A N/A output N/A N/A subprocess check_output cmd shell True N/A output N/A N/A N/A worker role shell N/A p N/A Process target N/A worker start kwargs N/A farm N/A echo shell 1 2 N/A N/A N/A p start fin N/A N/A N/A N/A N/A N/A N/A p terminate N/A N/A N/A p join N/A N/A N/A N/A request addfinalizer fin N/A p N/A N/A N/A pytest fixture scope session submit_job N/A N/A monkeypatch N/A N/A submitter N/A N/A job N/A N/A N/A N/A workflow_id run_id N/A N/A mass submit job local N/A N/A N/A monkeypatch setenv TEST_WORKFLOW_ID workflow_id N/A N/A N/A monkeypatch setenv TEST_RUN_ID run_id N/A N/A workflow_id run_id N/A N/A N/A submitter N/A workflow_id N/A N/A N/A os environ get TEST_WORKFLOW_ID None N/A run_id N/A N/A N/A os environ get TEST_RUN_ID None N/A N/A N/A workflow_id N/A run_id N/A N/A N/A N/A N/A is_job_done workflow_id run_id N/A N/A N/A N/A aws swf terminate-workflow-execution --workflow-id workflow_id --run-id run_id --child-policy TERMINATE reason TEST FINISHED region N/A config REGION domain N/A config DOMAIN N/A N/A N/A monkeypatch delenv TEST_WORKFLOW_ID N/A N/A N/A monkeypatch delenv TEST_RUN_ID N/A N/A pytest yield_fixture iter_workflow_execution_history N/A N/A workflow_id run_id reverse_order ignore_decision_task N/A False True N/A N/A client N/A N/A boto3 client swf region_name N/A config REGION config N/A Config connect_timeout N/A config CONNECT_TIMEOUT read_timeout N/A config READ_TIMEOUT N/A paginator N/A N/A client get_paginator get_workflow_execution_history N/A res N/A N/A paginator paginate domain N/A config DOMAIN execution N/A workflowId runId workflow_id run_id reverseOrder reverse_order N/A N/A event N/A res N/A events N/A N/A N/A ignore_decision_task N/A N/A N/A event N/A eventType startswith DecisionTask N/A N/A N/A N/A event N/A get_execution_info N/A N/A workflow_id run_id N/A N/A N/A lines N/A N/A aws swf describe-workflow-execution --execution N/A workflowId=%s,runId=%s N/A workflow_id run_id region N/A config REGION domain N/A config DOMAIN N/A info N/A N/A json loads N/A N/A join N/A l N/A l lines N/A info N/A is_job_done N/A N/A workflow_id run_id N/A N/A N/A info N/A get_execution_info workflow_id run_id N/A N/A N/A N/A info N/A executionInfo N/A executionStatus CLOSED N/A get_close_status N/A N/A workflow_id run_id N/A N/A N/A info N/A get_execution_info workflow_id run_id N/A N/A N/A N/A info N/A executionInfo N/A executionStatus CLOSED N/A N/A None N/A N/A N/A N/A info N/A executionInfo N/A closeStatus N/A test_start_job N/A N/A worker submit_job N/A N/A N/A N/A Job JobName job N/A N/A N/A Task TaskName N/A N/A N/A Task SubTaskName N/A N/A N/A Action msg Action here at $(date). _role echo N/A N/A Action msg Action here at $(date). _role echo N/A N/A Action msg Action here at $(date). _role echo N/A N/A workflow_id run_id N/A submit_job job N/A N/A N/A is_job_done workflow_id run_id N/A N/A wait N/A N/A N/A time sleep 3 N/A N/A N/A get_close_status workflow_id run_id COMPLETED N/A test_unexpected_keywork_arguments_of_action N/A N/A worker submit_job N/A N/A N/A N/A Job Job job N/A N/A N/A Task Task N/A N/A N/A Action wrong_input Action here at $(date). _role echo N/A N/A workflow_id run_id N/A submit_job job N/A N/A N/A is_job_done workflow_id run_id N/A N/A wait N/A N/A N/A time sleep 3 N/A N/A N/A get_close_status workflow_id run_id FAILED N/A event N/A iter_workflow_execution_history workflow_id run_id reverse_order True N/A N/A N/A N/A event N/A eventType WorkflowExecutionFailed N/A attr N/A event N/A workflowExecutionFailedEventAttributes N/A N/A got an unexpected keyword argument N/A attr N/A reason N/A N/A test_parallel_tasks N/A N/A worker submit_job N/A N/A N/A N/A Job Job parallel True job N/A N/A N/A Task Task1 N/A N/A N/A Action cmd sleep 10 _role shell N/A N/A Task Task2 N/A N/A N/A Action cmd sleep 8 _role shell N/A N/A workflow_id run_id N/A submit_job job N/A N/A N/A is_job_done workflow_id run_id N/A N/A wait N/A N/A N/A time sleep 3 N/A N/A N/A get_close_status workflow_id run_id COMPLETED N/A completed_child_workflows N/A set N/A event N/A iter_workflow_execution_history workflow_id run_id N/A N/A N/A N/A event N/A eventType ChildWorkflowExecutionStarted N/A N/A N/A attr N/A event N/A childWorkflowExecutionStartedEventAttributes N/A wid N/A N/A attr N/A workflowExecution N/A workflowId N/A rid N/A N/A attr N/A workflowExecution N/A runId N/A N/A N/A get_close_status wid rid COMPLETED N/A N/A N/A completed_child_workflows add N/A N/A - join N/A N/A N/A wid split - N/A -6 N/A N/A completed_child_workflows N/A set N/A Task1 Task2 N/A completed_child_workflows N/A N/A start_time N/A N/A event N/A iter_workflow_execution_history workflow_id run_id N/A N/A N/A N/A event N/A eventType ChildWorkflowExecutionStarted N/A N/A N/A attr N/A event N/A childWorkflowExecutionStartedEventAttributes N/A wid N/A N/A attr N/A workflowExecution N/A workflowId N/A task N/A N/A - join N/A N/A N/A wid split - N/A -6 N/A N/A start_time N/A task N/A N/A arrow get N/A event N/A eventTimestamp N/A N/A N/A abs N/A N/A start_time N/A Task1 N/A start_time N/A Task2 N/A timedelta seconds 5 N/A test_handle_task_error N/A N/A worker submit_job N/A N/A N/A N/A Job Job job N/A N/A N/A Task title Task N/A N/A N/A Action cmd fakecmd _role shell N/A N/A Action cmd echo "an error occurred" _role shell _whenerror True N/A N/A workflow_id run_id N/A submit_job job N/A N/A N/A is_job_done workflow_id run_id N/A N/A wait N/A N/A N/A time sleep 3 N/A N/A N/A get_close_status workflow_id run_id FAILED N/A