U W+d.@sdZGdddeZdS)z/ Helper class for creating decision responses. c@seZdZdZddZdddZddZdd d Zdd d Zd d dZ d!ddZ d"ddZ d#ddZ ddZ d$ddZd%ddZd&ddZdS)'Layer1Decisionsz Use this object to build a list of decisions for a decision response. Each method call will add append a new decision. Retrieve the list of decisions from the _data attribute. cCs g|_dS)N)_data)selfr=/tmp/pip-unpacked-wheel-dlxw5sjy/boto/swf/layer1_decisions.py__init__ szLayer1Decisions.__init__Nc Csi} d| d<i} | d<|| d<||d| d<|dk rBd|i| d <|dk rR|| d <|dk rb|| d <|dk rr|| d <|dk r|| d <| dk r| | d<| dk r| | d<|j| dS)a Schedules an activity task. :type activity_id: string :param activity_id: The activityId of the type of the activity being scheduled. :type activity_type_name: string :param activity_type_name: The name of the type of the activity being scheduled. :type activity_type_version: string :param activity_type_version: The version of the type of the activity being scheduled. :type task_list: string :param task_list: If set, specifies the name of the task list in which to schedule the activity task. If not specified, the defaultTaskList registered with the activity type will be used. Note: a task list for this activity task must be specified either as a default for the activity type or through this field. If neither this field is set nor a default task list was specified at registration time then a fault will be returned. ZScheduleActivityTask decisionTypeZ&scheduleActivityTaskDecisionAttributes activityIdnameversionZ activityTypeNr taskListcontrolZheartbeatTimeoutZscheduleToCloseTimeoutZscheduleToStartTimeoutZstartToCloseTimeoutinputrappend) r activity_idZactivity_type_nameZactivity_type_version task_listr Zheartbeat_timeoutZschedule_to_close_timeoutZschedule_to_start_timeoutstart_to_close_timeoutroattrsrrrschedule_activity_tasks,#   z&Layer1Decisions.schedule_activity_taskcCs0i}d|d<i}|d<||d<|j|dS)a Attempts to cancel a previously scheduled activity task. If the activity task was scheduled but has not been assigned to a worker, then it will be canceled. If the activity task was already assigned to a worker, then the worker will be informed that cancellation has been requested in the response to RecordActivityTaskHeartbeat. ZRequestCancelActivityTaskrZ+requestCancelActivityTaskDecisionAttributesrNr)rrrrrrrrequest_cancel_activity_taskKs  z,Layer1Decisions.request_cancel_activity_taskcCs@i}d|d<i}|d<||d<|dk r0||d<|j|dS)a Records a MarkerRecorded event in the history. Markers can be used for adding custom information in the history for instance to let deciders know that they do not need to look at the history beyond the marker event. Z RecordMarkerrZrecordMarkerDecisionAttributesZ markerNameNdetailsr)rZ marker_namerrrrrr record_markerZs zLayer1Decisions.record_markercCs8i}d|d<i}|d<|dk r(||d<|j|dS)zu Closes the workflow execution and records a WorkflowExecutionCompleted event in the history ZCompleteWorkflowExecutionrZ+completeWorkflowExecutionDecisionAttributesNresultr)rrrrrrrcomplete_workflow_executionis  z+Layer1Decisions.complete_workflow_executioncCsHi}d|d<i}|d<|dk r(||d<|dk r8||d<|j|dS)zs Closes the workflow execution and records a WorkflowExecutionFailed event in the history. ZFailWorkflowExecutionrZ'failWorkflowExecutionDecisionAttributesNreasonrr)rrrrrrrrfail_workflow_executionus z'Layer1Decisions.fail_workflow_executioncCs8i}d|d<i}|d<|dk r(||d<|j|dS)zu Closes the workflow execution and records a WorkflowExecutionCanceled event in the history. ZCancelWorkflowExecutionrZ*cancelWorkflowExecutionsDecisionAttributesNrr)rrrrrrrcancel_workflow_executionss  z*Layer1Decisions.cancel_workflow_executionsc Csi}d|d<i} |d<|dk r(|| d<|dk r8|| d<|dk rH|| d<|dk rX|| d<|dk rld |i| d <|dk r||| d <|dk r|| d <|j|dS) z Closes the workflow execution and starts a new workflow execution of the same type using the same workflow id and a unique run Id. A WorkflowExecutionContinuedAsNew event is recorded in the history. ZContinueAsNewWorkflowExecutionrZ0continueAsNewWorkflowExecutionDecisionAttributesN childPolicyexecutionStartToCloseTimeoutrtagListr r taskStartToCloseTimeoutZworkflowTypeVersionr) r child_policy execution_start_to_close_timeoutrtag_listrrworkflow_type_versionrrrrr"continue_as_new_workflow_executions$   z2Layer1Decisions.continue_as_new_workflow_executioncCsHi}d|d<i}|d<||d<||d<|dk r8||d<|j|dS)z Starts a timer for this workflow execution and records a TimerStarted event in the history. This timer will fire after the specified delay and record a TimerFired event. Z StartTimerrZstartTimerDecisionAttributesZstartToFireTimeouttimerIdNr r)rZstart_to_fire_timeouttimer_idr rrrrr start_timers  zLayer1Decisions.start_timercCs0i}d|d<i}|d<||d<|j|dS)zn Cancels a previously started timer and records a TimerCanceled event in the history. Z CancelTimerrZcancelTimerDecisionAttributesr(Nr)rr)rrrrr cancel_timers  zLayer1Decisions.cancel_timercCshi}d|d<i}|d<||d<||d<|dk r8||d<|dk rH||d<|dk rX||d <|j|dS) z Requests a signal to be delivered to the specified external workflow execution and records a SignalExternalWorkflowExecutionInitiated event in the history. ZSignalExternalWorkflowExecutionrZ1signalExternalWorkflowExecutionDecisionAttributes workflowIdZ signalNameNrunIdr rr)r workflow_idZ signal_namerun_idr rrrrrr"signal_external_workflow_executions  z2Layer1Decisions.signal_external_workflow_executioncCsPi}d|d<i}|d<||d<|dk r0||d<|dk r@||d<|j|dS)z Requests that a request be made to cancel the specified external workflow execution and records a RequestCancelExternalWorkflowExecutionInitiated event in the history. Z&RequestCancelExternalWorkflowExecutionrZ8requestCancelExternalWorkflowExecutionDecisionAttributesr,Nr r-r)rr.r r/rrrrr*request_cancel_external_workflow_executions  z:Layer1Decisions.request_cancel_external_workflow_executionc Csi} d| d<i} | d<||d| d<|| d<|dk r>|| d<|dk rN|| d <|dk r^|| d <|dk rn|| d <|dk r~|| d <| dk rd | i| d<| dk r| | d<|j| dS)z Requests that a child workflow execution be started and records a StartChildWorkflowExecutionInitiated event in the history. The child workflow execution is a separate workflow execution with its own history. ZStartChildWorkflowExecutionrZ-startChildWorkflowExecutionDecisionAttributesr Z workflowTyper,Nrr r rr!r r r"r) rZworkflow_type_namer&r.r#r r$rr%rZtask_start_to_close_timeoutrrrrrstart_child_workflow_executions,   z.Layer1Decisions.start_child_workflow_execution)NNNNNNN)N)N)NN)N)NNNNNNN)N)NNN)NN)NNNNNNN)__name__ __module__ __qualname____doc__rrrrrrrr'r*r+r0r1r2rrrrrsR ;    #   rN)r6objectrrrrrs