| Server IP : 209.38.156.173 / Your IP : 216.73.216.122 [ Web Server : Apache/2.4.52 (Ubuntu) System : Linux lakekumayuhotel 5.15.0-136-generic #147-Ubuntu SMP Sat Mar 15 15:53:30 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.1.2-1ubuntu2.22 Disable Function : NONE Domains : 2 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/lib/python3/dist-packages/twisted/trial/_dist/__pycache__/ |
Upload File : |
o
�b/ � @ 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)�managercommands)�
TestResultc 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 � �� || _dS )z�
@param ampProtocol: The communication channel with the trial
distributed manager which collects all test results.
@type ampProtocol: C{AMP}
N)�super�__init__� ampProtocol)�selfr �� __class__� �D/usr/lib/python3/dist-packages/twisted/trial/_dist/workerreporter.pyr s
zWorkerReporter.__init__c C s& t |t�rt|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 �
_getFrames. s
"zWorkerReporter._getFramesc s* t � �|� |�� }| jjtj|d� dS )z&
Send a success over.
)�testNameN)r �
addSuccess�idr �
callRemoter �
AddSuccess)r
�testr r r
r r 7 s zWorkerReporter.addSuccessc �b t � �||� |�� }| �|�}|�� }t|j�}dd� | �|�D �}| jj t
j ||||d� dS )z%
Send an error over.
c S � g | ]}|�qS r
r
��.0r r
r
r �
<listcomp>H � z+WorkerReporter.addError.<locals>.<listcomp>)r r �
errorClassr N) r �addErrorr r �getErrorMessager �typer r r r �AddError)r
r r r r r' r r r
r r( ? �
�zWorkerReporter.addErrorc r! )z&
Send a Failure over.
c S r" r
r
r# r
r
r r% Z r& z-WorkerReporter.addFailure.<locals>.<listcomp>)r �fail� failClassr N) r �
addFailurer r r) r r* r r r r �
AddFailure)r
r r- r r r. r r r
r r/ Q r, zWorkerReporter.addFailurec s6 t � �||� t|�}|�� }| jjtj||d� dS )z#
Send a skip over.
)r �reasonN)r �addSkipr r r r r �AddSkip)r
r r1 r r r
r r2 c s
�zWorkerReporter.addSkipc C s |du r| j S |jS )zj
Get the reason for a C{Todo}.
If C{todo} is L{None}, return a sensible default.
N)�
_DEFAULT_TODOr1 )r
�todor
r
r �_getTodoReasonn s z WorkerReporter._getTodoReasonNc s@ t � �|||� |�� }|�� }| jjtj||| �|�d� dS )z0
Send an expected failure over.
)r r r5 N) r �addExpectedFailurer) r r r r �AddExpectedFailurer6 )r
r r r5 � errorMessager r r
r r7 y s
�z!WorkerReporter.addExpectedFailurec s4 t � �||� |�� }| jjtj|| �|�d� dS )z2
Send an unexpected success over.
)r r5 N)r �addUnexpectedSuccessr r r r �AddUnexpectedSuccessr6 )r
r r5 r r r
r r: � s
�z#WorkerReporter.addUnexpectedSuccessc C s dS )z*
I{Don't} print a summary
Nr
)r
r
r
r � printSummary� s zWorkerReporter.printSummary)N)�__name__�
__module__� __qualname__�__doc__r4 r r r r r( r/ r2 r6 r7 r: r< �
__classcell__r
r
r r r s r N)
r@ �twisted.python.failurer �twisted.python.reflectr �twisted.trial._distr �twisted.trial.reporterr r r
r
r
r �<module> s