Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/trial/_dist/__pycache__/disttrial.cpython-39.pyc
Ðазад
a k�h�! � @ s� d Z ddlZddlZddlmZ ddlmZ ddlmZ ddl m Z ddl m Z ddl mZmZ dd lmZ dd lmZmZ dd lmZ dd lmZ G d d� d�ZdS )z� This module contains the trial distributed runner, the management class responsible for coordinating all of trial's behavior at the highest level. @since: 12.3 � N)� DeferredList�� cooperate)�FilePath)� theSystemPath)� _iterateTests)�_WORKER_AMP_STDIN�_WORKER_AMP_STDOUT)� DistReporter)� LocalWorker�LocalWorkerAMP)� UncleanWarningsReporterWrapper)�_unusedTestDirectoryc @ s^ e Zd ZdZeZdd� Zdd d �Zd d � Zd d� Z dd� Z dd� Z de dfdd�Z dd� ZdS )�DistTrialRunneraY A specialized runner for distributed trial. The runner launches a number of local worker processes which will run tests. @ivar _workerNumber: the number of workers to be spawned. @type _workerNumber: C{int} @ivar _stream: stream which the reporter will use. @ivar _reporterFactory: the reporter class to be used. c C s. | j | j| j| jd�}| jr$t|�}| �|�S )zL Make reporter factory, and wrap it with a L{DistReporter}. )Zrealtime)�_reporterFactory�_stream� _tbformat� _rterrors�_uncleanWarningsr �_distReporterFactory)�self�reporter� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/trial/_dist/disttrial.py� _makeResult* s �zDistTrialRunner._makeResultN�defaultF�test.log� _trial_tempc C s` || _ || _|| _|d u r tj}|| _|| _|| _|| _d | _ | | _ || _ d | _ d | _ d| _d S )NF)� _workerNumber�_workerArgumentsr �sys�stdoutr r r r �_result�_workingDirectory�_logFileZ_logFileObserverZ_logFileObjectZ _logWarnings) r ZreporterFactory� workerNumberZworkerArguments�streamZtracebackFormatZrealTimeErrorsZuncleanWarningsZlogfile�workingDirectoryr r r �__init__5 s zDistTrialRunner.__init__c C s |� � dS )z� Write test run final outcome to result. @param result: A C{TestResult} which will print errors and the summary. N)�done)r �resultr r r � writeResultsQ s z DistTrialRunner.writeResultsc s � �fdd�t |�D �S )aY Create local worker protocol instances and return them. @param protocols: An iterable of L{LocalWorkerAMP} instances. @param workingDirectory: The base path in which we should run the workers. @type workingDirectory: C{str} @return: A list of C{quantity} C{LocalWorker} instances. c s, g | ]$\}}t |tj��t|��� j��qS r )r �os�path�join�strr$ )�.0�x�protocol�r r' r r � <listcomp>e s �z6DistTrialRunner.createLocalWorkers.<locals>.<listcomp>)� enumerate)r � protocolsr' r r3 r �createLocalWorkersY s �z"DistTrialRunner.createLocalWorkersc C sv t d jj}ddddddtdtdi}tj�� }tj� t j�|d< |D ],}t j |g}|� |� ||t j |||d� qDd S ) a Spawn processes from a list of process protocols. @param spawner: A C{IReactorProcess.spawnProcess} implementation. @param protocols: An iterable of C{ProcessProtocol} instances. @param arguments: Extra arguments passed to the processes. z twisted.trial._dist.workertrialr �w� �r� � PYTHONPATH)�args�childFDs�envN) r ZfilePathr- r r r, �environ�copy�pathsepr. r � executable�extend) r Zspawnerr6 � argumentsZworkertrialPathr> r@ �workerr= r r r �launchWorkerProcessesj s � z%DistTrialRunner.launchWorkerProcessesc s6 � fdd��� ��fdd��|�fdd�|D ��� � S )a� Drive a L{LocalWorkerAMP} instance, iterating the tests and calling C{run} for every one of them. @param worker: The L{LocalWorkerAMP} to drive. @param result: The global L{DistReporter} instance. @param testCases: The global list of tests to iterate. @param cooperate: The cooperate function to use, to be customized in tests. @type cooperate: C{function} @return: A C{Deferred} firing when all the tests are finished. c s � j �|| � | S �N)�originalZ addFailure)�error�case)r* r r � resultErrback� s z3DistTrialRunner._driveWorker.<locals>.resultErrbackc s �� | � �}|��| � |S rH )�runZ addErrback)rK �d)r* rL rF r r �task� s z*DistTrialRunner._driveWorker.<locals>.taskc 3 s | ]}� |�V qd S rH r )r0 rK )rO r r � <genexpr>� � z/DistTrialRunner._driveWorker.<locals>.<genexpr>)ZwhenDone)r rF r* � testCasesr r )r* rL rO rF r � _driveWorker� s z DistTrialRunner._driveWorkerc sB �du rddl m� ��� �� �� }�j�d|f � |sT� ��j� ���� �S t t �j ��\}� t |�j �}dd� t|�D �� ��� |j�}dd� |D �����j|�j� � ���� fdd ��g � ����� fd d ���� � fd d �} ��� fdd�} ��fdd���� } | ��d� | �| � ��dd| � ��� �S )a{ Spawn local worker processes and load tests. After that, run them. @param suite: A tests suite to be run. @param reactor: The reactor to use, to be customized in tests. @type reactor: A provider of L{twisted.internet.interfaces.IReactorProcess} @param cooperate: The cooperate function to use, to be customized in tests. @type cooperate: C{function} @param untilFailure: If C{True}, continue to run the tests until they fail. @type untilFailure: C{bool}. @return: The test result. @rtype: L{DistReporter} Nr )�reactorzRunning %d tests. c S s g | ] }t � �qS r )r )r0 r1 r r r r4 � rQ z'DistTrialRunner.run.<locals>.<listcomp>c S s g | ] }|j �qS r )Z endDeferred)r0 rF r r r r4 � rQ c sD t tt����} g }� D ] }|��j|�| �d�� qt|ddd�S )Nr T)� consumeErrorsZfireOnOneErrback)�iter�listr �appendrS r )rR ZworkerDeferredsrF )� ampWorkersr r* r �suiter r �runTests� s ��z%DistTrialRunner.run.<locals>.runTestsc sJ �r�j �d|f � ���� �s(d S ��� s4d S �� }|�� |d �S )Nz Test Pass %d r9 )r �writer+ Z wasSuccessful� addCallback)�ign�nrN )�nextRunr* r[ r � untilFailurer r r` � s z$DistTrialRunner.run.<locals>.nextRunc s" �� � �s ��d � � �� d S rH )�unlockrX �stop�r^ )rT �stopping� testDirLockr r rc � s z!DistTrialRunner.run.<locals>.stopc s( �s$�� d � t�dd�} | �� �S d S )NT)rU )rX r r] )rN )�continueShutdown�processEndDeferredsre r r �beforeShutDown� s z+DistTrialRunner.run.<locals>.beforeShutDownc s �� � � | S rH )r+ rd )r* r r r rg � s z-DistTrialRunner.run.<locals>.continueShutdownr9 �before�shutdown)Ztwisted.internetrT r ZcountTestCasesr r\ rM rI r+ r r r# �minr �ranger7 r- rG Z spawnProcessr r] ZaddBothZaddSystemEventTrigger) r rZ rT r ra �countZtestDirr% �workersrc ri rN r ) rY rg r r` rh rT r* r[ r re rZ rf ra r rM � s6 zDistTrialRunner.runc C s | j |dd�S )z| Run the tests with local worker processes until they fail. @param suite: A tests suite to be run. T)ra )rM )r rZ r r r �runUntilFailure� s z DistTrialRunner.runUntilFailure)Nr FFr r )�__name__� __module__� __qualname__�__doc__r r r r( r+ r7 rG rS r rM rp r r r r r s � Zr )rt r, r Ztwisted.internet.deferr Ztwisted.internet.taskr Ztwisted.python.filepathr Ztwisted.python.modulesr Ztwisted.trial._asyncrunnerr Ztwisted.trial._distr r Z twisted.trial._dist.distreporterr Ztwisted.trial._dist.workerr r Ztwisted.trial.reporterr Ztwisted.trial.utilr r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка