File: //lib/python3/dist-packages/twisted/trial/_dist/__pycache__/workerreporter.cpython-38.pyc
U
W[� � @ sH d Z ddlmZ ddlmZ ddlmZ ddlmZ G dd� de�Z dS ) zZ
Test reporter forwarding test results over trial distributed AMP commands.
@since: 12.3
� )�Failure)�qual)�
TestResult)�managercommandsc s� e Zd ZdZdZ� fdd�Zdd� Zdd� Z� fd d
�Z� fd d �Z � fd
d�Z
� fdd�Z dd� Z d� fdd� Z
d� fdd� Zdd� Z� ZS ) �WorkerReportera
Reporter for trial's distributed workers. We send things not through a
stream, but through an C{AMP} protocol's C{callRemote} method.
@ivar _DEFAULT_TODO: Default message for expected failures and
unexpected successes, used only if a C{Todo} is not provided.
zTest expected to failc s t t| ��� || _dS )z�
@param ampProtocol: The communication channel with the trial
distributed manager which collects all test results.
@type ampProtocol: C{AMP}
N)�superr �__init__� ampProtocol)�selfr �� __class__� �D/usr/lib/python3/dist-packages/twisted/trial/_dist/workerreporter.pyr s zWorkerReporter.__init__c C s& t |t�r"t|d |d |d �S |S )zX
Convert a C{sys.exc_info()}-style tuple to a L{Failure}, if necessary.
� r � )�
isinstance�tupler )r
�errorr
r
r � _getFailure( s
zWorkerReporter._getFailurec C s4 g }|j D ]$}|�|d |d t|d �g� q
|S )z<
Extract frames from a C{Failure} instance.
r r r )�frames�extend�str)r
�failurer �framer
r
r �
_getFrames1 s
"zWorkerReporter._getFramesc s. t t| ��|� |�� }| jjtj|d� dS )z&
Send a success over.
)�testNameN)r r �
addSuccess�idr �
callRemoter Z
AddSuccess)r
�testr r r
r r ; s
�zWorkerReporter.addSuccessc sf t t| ��||� |�� }| �|�}|�� }t|j�}dd� | �|�D �}| j j
t j ||||d� dS )z%
Send an error over.
c S s g | ]}|�qS r
r
��.0r r
r
r �
<listcomp>N s z+WorkerReporter.addError.<locals>.<listcomp>)r r �
errorClassr N)
r r �addErrorr r �getErrorMessager �typer r r r ZAddError)r
r r r r r# r r r
r r$ E s
�zWorkerReporter.addErrorc sf t t| ��||� |�� }| �|�}|�� }t|j�}dd� | �|�D �}| j j
t j ||||d� dS )z&
Send a Failure over.
c S s g | ]}|�qS r
r
r r
r
r r" _ s z-WorkerReporter.addFailure.<locals>.<listcomp>)r �fail� failClassr N)
r r �
addFailurer r r% r r& r r r r Z
AddFailure)r
r r' r r r( r r r
r r) V s
�zWorkerReporter.addFailurec s: t t| ��||� t|�}|�� }| jjtj||d� dS )z#
Send a skip over.
)r �reasonN) r r �addSkipr r r r r ZAddSkip)r
r r* r r r
r r+ g s
�zWorkerReporter.addSkipc C s |dkr| j S |jS dS )zj
Get the reason for a C{Todo}.
If C{todo} is L{None}, return a sensible default.
N)�
_DEFAULT_TODOr* )r
�todor
r
r �_getTodoReasons s z WorkerReporter._getTodoReasonNc sD t t| ��|||� |�� }|�� }| jjtj||| � |�d� dS )z0
Send an expected failure over.
)r r r- N)
r r �addExpectedFailurer% r r r r ZAddExpectedFailurer. )r
r r r- Z errorMessager r r
r r/ s
�z!WorkerReporter.addExpectedFailurec s8 t t| ��||� |�� }| jjtj|| �|�d� dS )z2
Send an unexpected success over.
)r r- N) r r �addUnexpectedSuccessr r r r ZAddUnexpectedSuccessr. )r
r r- r r r
r r0 � s
�z#WorkerReporter.addUnexpectedSuccessc C s dS )z*
I{Don't} print a summary
Nr
)r
r
r
r � printSummary� s zWorkerReporter.printSummary)N)N)�__name__�
__module__� __qualname__�__doc__r, r r r r r$ r) r+ r. r/ r0 r1 �
__classcell__r
r
r r r s
r N)
r5 Ztwisted.python.failurer Ztwisted.python.reflectr Ztwisted.trial.reporterr Ztwisted.trial._distr r r
r
r
r �<module> s