|
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 : |
o
ckF[ 3 � @ s� d Z ddlZddlmZ ddlmZ ddlmZ ddd�Zdd� Z G d d
� d
e
�Z G d d � d e �Z G d
d� de �Z
G dd� de
�ZG dd� de
�ZG dd� de �ZG dd� de �ZG dd� de �ZdS )z@Object-oriented interface to SWF wrapping boto.swf.layer1.Layer1� N)�wraps)�Layer1)�Layer1Decisions��aws_access_key_id�aws_secret_access_keyc C s t �| |d�� dS )zSet default credentials.r N)�DEFAULT_CREDENTIALS�updater � r
�1/usr/lib/python3/dist-packages/boto/swf/layer2.py�set_default_credentials
s �r c @ s0 e Zd ZdZdZdZdZdZdd� Zdd� Z dS )�SWFBaseNc K sX dD ]}t �|�rt| |t | � q|D ]
}t| ||| � qt| j| j| jd�| _d S )Nr )�region)r �get�setattrr r r r �_swf)�self�kwargs�credkey�kwargr
r
r �__init__ s
� �zSWFBase.__init__c C s@ t | j�}t| d�r|dt t| d�� 7 }d| jj|t| �f S )N�version�-z<%s %r at 0x%x>)�str�name�hasattr�getattr� __class__�__name__�id)r �rep_strr
r
r �__repr__) s
zSWFBase.__repr__)
r �
__module__� __qualname__r �domainr r r r r! r
r
r
r r
s
r
c @ s� e Zd ZdZdZdZeej�dd� �Z eej
�dd� �Z eej �dd � �Z
eej�dd d ��Zeej�dd
d��Zddd�Zeej�dd� �Zeej�dd� �ZdS )�DomainzSimple Workflow Domain.N� c C s | j �| j�S )zDescribeDomain.)r �describe_domainr �r r
r
r �describe5 s zDomain.describec C s | j �| j� dS )�DeprecateDomainN)r �deprecate_domainr r( r
r
r � deprecate: s zDomain.deprecatec C s | j �| jt| j�| j� dS )zRegisterDomain.N)r �register_domainr r � retention� descriptionr( r
r
r �register? s �zDomain.register�
REGISTEREDc K �v | j j| j|fi |��}g }|d D ]&}|d }|d= |�|� |�| j| j| j| jd�� |�tdi |��� q|S )zListActivityTypes.� typeInfos� activityType�r r r$ r Nr
) r �list_activity_typesr r r r r �append� ActivityType)r �statusr � act_types� act_objects�act_args� act_identr
r
r �
activitiesE s
�zDomain.activitiesc K r2 )zListWorkflowTypes.r3 � workflowTyper5 Nr
) r �list_workflow_typesr r r r r r7 � WorkflowType)r r9 r �wf_types�
wf_objects�wf_args�wf_identr
r
r � workflowsW s
�zDomain.workflowsFc K s� |r| j j| jfi |��}nd|vrt�� d |d< | j j| jfi |��}g }|d D ]+}dD ]}|| }||= |�|� q/|�| j| j| j| jd�� |� t
di |��� q+|S )z�List list open/closed executions.
For a full list of available parameters refer to
:py:func:`boto.swf.layer1.Layer1.list_closed_workflow_executions` and
:py:func:`boto.swf.layer1.Layer1.list_open_workflow_executions`
� oldest_datei�Q �executionInfos)� executionr? r5 Nr
) r � list_closed_workflow_executionsr �time� list_open_workflow_executionsr r r r r7 �WorkflowExecution)r �closedr �
executions� exe_objects�exe_args�
nested_key� nested_dictr
r
r rO j s. �� �zDomain.executionsc C � | j �| j|�S )zCountPendingActivityTasks.)r � count_pending_activity_tasksr �r � task_listr
r
r rU � � z#Domain.count_pending_activity_tasksc C rT )zCountPendingDecisionTasks.)r � count_pending_decision_tasksr rV r
r
r rY � rX z#Domain.count_pending_decision_tasks)r1 )F)r r" r# �__doc__r/ r. r r r' r) r+ r, r- r0 r6 r> r@ rF rO rU rY r
r
r
r r% / s&
!
r% c @ s e Zd ZdZdZdZdd� ZdS )�ActorNc C s t � �)z To be overloaded by subclasses.)�NotImplementedErrorr( r
r
r �run� s z Actor.run)r r" r# rW �last_tasktokenr$ r] r
r
r
r r[ � s
r[ c @ sr e Zd ZdZeej�d
dd��Zeej�d
dd��Z eej
�ddd��Z eej �d
d d
��Z
eej�d d � �ZdS )�ActivityWorkerz/Base class for SimpleWorkflow activity workers.Nc C � |du r| j }| j�||�S )z RespondActivityTaskCanceled.N)r^ r � respond_activity_task_canceled�r �
task_token�detailsr
r
r �cancel� � zActivityWorker.cancelc C r` )z RespondActivityTaskCompleted.N)r^ r � respond_activity_task_completed)r rc �resultr
r
r �complete� rf zActivityWorker.completec C s |du r| j }| j�|||�S )zRespondActivityTaskFailed.N)r^ r � respond_activity_task_failed)r rc rd �reasonr
r
r �fail� s
�zActivityWorker.failc C r` )z RecordActivityTaskHeartbeat.N)r^ r � record_activity_task_heartbeatrb r
r
r � heartbeat� rf zActivityWorker.heartbeatc K �F | j }d|v r|�d�}|d= | jj| j|fi |��}|�d�| _|S )zPollForActivityTask.rW � taskToken)rW r r �poll_for_activity_taskr$ r^ )r r rW �taskr
r
r �poll� �
� zActivityWorker.poll�NN)NNN)r r" r# rZ r r ra re rg ri rj rl rm rn rq rs r
r
r
r r_ � s r_ c @ s6 e Zd ZdZeej�ddd��Zeej�dd� �Z dS )�Deciderz'Base class for SimpleWorkflow deciders.Nc K s4 t |t�r|j}|du r| j}| jj||fi |��S )z RespondDecisionTaskCompleted.N)�
isinstancer �_datar^ r � respond_decision_task_completed)r rc � decisionsr r
r
r ri � s
�zDecider.completec K ro )zPollForDecisionTask.rW rp )rW r r �poll_for_decision_taskr$ r^ )r r rW �
decision_taskr
r
r rs � rt z Decider.pollru )
r r" r# rZ r r ry ri r{ rs r
r
r
r rv � s
rv c @ sd e Zd ZdZdZdZdZeej �dd� �Z
eej �dd� �Z eej
�dd � �Zeej�d
d � �ZdS ) rA zA versioned workflow type.N� TERMINATEc C � | j �| j| j| j�S )zDescribeWorkflowType.)r �describe_workflow_typer$ r r r( r
r
r r) � � �zWorkflowType.describec K s8 dddd�}|� |� | jj| j| j| jfi |�� dS )zRegisterWorkflowType.�3600�300r} )�(default_execution_start_to_close_timeout�#default_task_start_to_close_timeout�default_child_policyN)r r �register_workflow_typer$ r r �r r �argsr
r
r r0 � s �
�zWorkflowType.registerc C s | j �| j| j| j� dS )zDeprecateWorkflowType.N)r �deprecate_workflow_typer$ r r r( r
r
r r, s zWorkflowType.deprecatec K s� d|v r |d }|d= n d| j | jt�� f }dD ]
}|�|t| |��||< q| jj| j|| j | jfi |��d }t| j | j|| j|| j | j
d�S )zStartWorkflowExecution.� workflow_idz%s-%s-%i)rW � child_policy�runId)r r r� r$ �
workflowIdr r ) r r rK r r r �start_workflow_executionr$ rM r r )r r r� �def_attr�run_idr
r
r �start s$ ���
�zWorkflowType.start)r r" r# rZ r rW r� r r r r) r� r0 r� r, r� r� r
r
r
r rA � s
rA c @ sr e Zd ZdZdZdZeej�dd� �Z eej
�dd� �Z eej �dd� �Z
eej�d d
� �Zeej�d d � �ZdS )
rM zAn instance of a workflow.Nc K s | j j| j|| jfi |�� dS )zSignalWorkflowExecution.N)r �signal_workflow_executionr$ r� )r �signamer r
r
r �signal s
�
�zWorkflowExecution.signalc K s | j j| j| jfi |��S )z$TerminateWorkflowExecution (p. 103).)r � terminate_workflow_executionr$ r� �r r r
r
r � terminate% s
��zWorkflowExecution.terminatec K s" | j j| j| j| jfi |��d S )z GetWorkflowExecutionHistory.�events)r � get_workflow_execution_historyr$ r� r� r� r
r
r �history+ s ���zWorkflowExecution.historyc C r~ )zDescribeWorkflowExecution.)r �describe_workflow_executionr$ r� r� r( r
r
r r) 1 r� zWorkflowExecution.describec C r~ )z RequestCancelWorkflowExecution.)r �!request_cancel_workflow_executionr$ r� r� r( r
r
r �request_cancel7 s
�z WorkflowExecution.request_cancel)r r" r# rZ r� r� r r r� r� r� r� r� r� r� r) r� r� r
r
r
r rM s
rM c @ sJ e Zd ZdZdZeej�dd� �Zeej �dd� �Z
eej �dd� �Z dS ) r8 zA versioned activity type.Nc C r~ )zDeprecateActivityType.)r �deprecate_activity_typer$ r r r( r
r
r r, D r� zActivityType.deprecatec C r~ )zDescribeActivityType.)r �describe_activity_typer$ r r r( r
r
r r) J r� zActivityType.describec K s: ddddd�}|� |� | jj| j| j| jfi |�� dS )zRegisterActivityType.�600�3900r� r� )� default_task_heartbeat_timeout�&default_task_schedule_to_close_timeout�&default_task_schedule_to_start_timeoutr� N)r r �register_activity_typer$ r r r� r
r
r r0 P s �
�zActivityType.register)
r r" r# rZ r r r r� r, r� r) r� r0 r
r
r
r r8 > s
r8 )rZ rK � functoolsr �boto.swf.layer1r �boto.swf.layer1_decisionsr r r �objectr
r% r[ r_ rv rA rM r8 r
r
r
r �<module> s" �g
-0&