https://t.me/RX1948
Server : Apache
System : Linux iad1-shared-b8-43 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64
User : dh_edsupp ( 6597262)
PHP Version : 8.2.26
Disable Function : NONE
Directory :  /lib/python3/dist-packages/boto/swf/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : //lib/python3/dist-packages/boto/swf/__pycache__/layer1_decisions.cpython-310.pyc
o

ckF[�.�@sdZGdd�de�ZdS)z/
Helper class for creating decision responses.
c@s�eZdZdZdd�Z							ddd�Zdd�Zdd	d
�Zddd�Zdd
d�Z	ddd�Z
							ddd�Z	ddd�Zdd�Z
			d dd�Z		ddd�Z							ddd�ZdS)!�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)�self�r�;/usr/lib/python3/dist-packages/boto/swf/layer1_decisions.py�__init__
s
zLayer1Decisions.__init__Nc
Cs�i}d|d<i}|d<||d<||d�|d<|dur!d|i|d	<|dur)||d
<|dur1||d<|dur9||d<|durA||d
<|	durI|	|d<|
durQ|
|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.
        �ScheduleActivityTask�decisionType�&scheduleActivityTaskDecisionAttributes�
activityId��name�version�activityTypeNr
�taskList�control�heartbeatTimeout�scheduleToCloseTimeout�scheduleToStartTimeout�startToCloseTimeout�input�r�append)
r�activity_id�activity_type_name�activity_type_version�	task_listr�heartbeat_timeout�schedule_to_close_timeout�schedule_to_start_timeout�start_to_close_timeoutr�o�attrsrrr�schedule_activity_tasks,#
�z&Layer1Decisions.schedule_activity_taskcC�0i}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.
        �RequestCancelActivityTaskr	�+requestCancelActivityTaskDecisionAttributesrNr)rrr!r"rrr�request_cancel_activity_taskKs
	z,Layer1Decisions.request_cancel_activity_taskcCs@i}d|d<i}|d<||d<|dur||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.
        �RecordMarkerr	�recordMarkerDecisionAttributes�
markerNameN�detailsr)r�marker_namer+r!r"rrr�
record_markerZszLayer1Decisions.record_markercC�8i}d|d<i}|d<|dur||d<|j�|�dS)zu
        Closes the workflow execution and records a WorkflowExecutionCompleted
        event in the history
        �CompleteWorkflowExecutionr	�+completeWorkflowExecutionDecisionAttributesN�resultr)rr1r!r"rrr�complete_workflow_executioni�z+Layer1Decisions.complete_workflow_executioncCsHi}d|d<i}|d<|dur||d<|dur||d<|j�|�dS)zs
        Closes the workflow execution and records a
        WorkflowExecutionFailed event in the history.
        �FailWorkflowExecutionr	�'failWorkflowExecutionDecisionAttributesN�reasonr+r)rr6r+r!r"rrr�fail_workflow_executionusz'Layer1Decisions.fail_workflow_executioncCr.)zu
        Closes the workflow execution and records a WorkflowExecutionCanceled
        event in the history.
        �CancelWorkflowExecutionr	�*cancelWorkflowExecutionsDecisionAttributesNr+r)rr+r!r"rrr�cancel_workflow_executions�r3z*Layer1Decisions.cancel_workflow_executionsc
Cs�i}d|d<i}	|d<|dur||	d<|dur||	d<|dur$||	d<|dur,||	d<|dur6d	|i|	d
<|dur>||	d<|durF||	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.
        �ContinueAsNewWorkflowExecutionr	�0continueAsNewWorkflowExecutionDecisionAttributesN�childPolicy�executionStartToCloseTimeoutr�tagListr
r�taskStartToCloseTimeout�workflowTypeVersionr)
r�child_policy� execution_start_to_close_timeoutr�tag_listrr �workflow_type_versionr!r"rrr�"continue_as_new_workflow_execution�s$
z2Layer1Decisions.continue_as_new_workflow_executioncCsHi}d|d<i}|d<||d<||d<|dur||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.
        �
StartTimerr	�startTimerDecisionAttributes�startToFireTimeout�timerIdNrr)r�start_to_fire_timeout�timer_idrr!r"rrr�start_timer�s	zLayer1Decisions.start_timercCr$)zn
        Cancels a previously started timer and records a TimerCanceled
        event in the history.
        �CancelTimerr	�cancelTimerDecisionAttributesrJNr)rrLr!r"rrr�cancel_timer�s
zLayer1Decisions.cancel_timercCshi}d|d<i}|d<||d<||d<|dur||d<|dur$||d<|dur,||d	<|j�|�dS)
z�
        Requests a signal to be delivered to the specified external workflow
        execution and records a SignalExternalWorkflowExecutionInitiated
        event in the history.
        �SignalExternalWorkflowExecutionr	�1signalExternalWorkflowExecutionDecisionAttributes�
workflowId�
signalNameN�runIdrrr)r�workflow_id�signal_name�run_idrrr!r"rrr�"signal_external_workflow_execution�sz2Layer1Decisions.signal_external_workflow_executioncCsPi}d|d<i}|d<||d<|dur||d<|dur ||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.
        �&RequestCancelExternalWorkflowExecutionr	�8requestCancelExternalWorkflowExecutionDecisionAttributesrSNrrUr)rrVrrXr!r"rrr�*request_cancel_external_workflow_execution�s
z:Layer1Decisions.request_cancel_external_workflow_executionc
Cs�i}d|d<i}|d<||d�|d<||d<|dur||d<|dur'||d	<|dur/||d
<|dur7||d<|dur?||d<|	durId
|	i|d<|
durQ|
|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.
        �StartChildWorkflowExecutionr	�-startChildWorkflowExecutionDecisionAttributesr�workflowTyperSNr=rr>rr?r
rr@r)
r�workflow_type_namerErVrBrrCrrDr�task_start_to_close_timeoutr!r"rrr�start_child_workflow_execution�s,
�z.Layer1Decisions.start_child_workflow_execution)NNNNNNNr)NN)NNN)�__name__�
__module__�__qualname__�__doc__rr#r'r-r2r7r:rFrMrPrYr\rbrrrrrsT
�;





�#
�
�
��rN)rf�objectrrrrr�<module>s

https://t.me/RX1948 - 2025