Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
doctorondemand
doctorondemand / supervisor python
Repository URL to install this package:
|
Version:
4.2.1 ▾
|
U
VƧ\¸Q ã @ s¨ d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlmZ G dd dejZG dd d ejZ G d
d d ejZ
G d d
d
ejZ dd Z e
dkr¤ejdd dS )é N)Ú DummyOptions)Ú DummyPConfig)Ú DummyProcess)Ú
DummyEventc @ sL e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z dd Z
dS )Ú"EventSubscriptionNotificationTestsc C s ddl m} g |jd d
< d S ©Nr ©Úevents©Ú
supervisorr Ú callbacks©Úselfr © r ú+./build/lib/supervisor/tests/test_events.pyÚsetUp
s z(EventSubscriptionNotificationTests.setUpc C s ddl m} g |jd d
< d S r r
r
r r r ÚtearDown s z+EventSubscriptionNotificationTests.tearDownc C s, ddl m} | d d ¡ | |jdg¡ d S ©Nr r )NN)r r Z subscribeÚ assertEqualr r
r r r Útest_subscribe s z1EventSubscriptionNotificationTests.test_subscribec C sB ddl m} dddg|jd d
< | dd¡ | |jddg¡ d S )Nr r )é r )é r )é r r )r r r Z unsubscriber r
r r r Útest_unsubscribe s z3EventSubscriptionNotificationTests.test_unsubscribec C s6 ddl m} dg|jd d
< | ¡ | |jg ¡ d S r )r r r Úclearr r
r r r Ú
test_clear s z-EventSubscriptionNotificationTests.test_clearc sN ddl m} g fdd}t|fg|jd d
< | t ¡ | dg¡ d S )Nr r c s d¡ d S ©Nr ©Úappend©Úevent©ÚLr r Úcallback& s zEEventSubscriptionNotificationTests.test_notify_true.<locals>.callbackr ©r r r r Únotifyr )r r r# r r! r Útest_notify_true# s z3EventSubscriptionNotificationTests.test_notify_truec sZ ddl m} g fdd}G dd d}||fg|jd d
< | t ¡ | g ¡ d S )Nr r c s d¡ d S r r r r! r r r# / s zFEventSubscriptionNotificationTests.test_notify_false.<locals>.callbackc @ s e Zd ZdS )zJEventSubscriptionNotificationTests.test_notify_false.<locals>.AnotherEventN©Ú__name__Ú
__module__Ú __qualname__r r r r Ú AnotherEvent1 s r+ )r r r r% r r )r r r# r+ r r! r Útest_notify_false, s z4EventSubscriptionNotificationTests.test_notify_falsec s^ ddl m} g fdd}G dd dt}t|fg|jd d
< | | ¡ | dg¡ d S )Nr r c s d¡ d S r r r r! r r r# : s zMEventSubscriptionNotificationTests.test_notify_via_subclass.<locals>.callbackc @ s e Zd ZdS )zSEventSubscriptionNotificationTests.test_notify_via_subclass.<locals>.ASubclassEventNr' r r r r ÚASubclassEvent< s r- r r$ )r r r# r- r r! r Útest_notify_via_subclass7 s z;EventSubscriptionNotificationTests.test_notify_via_subclassN) r( r) r* r r r r r r& r, r. r r r r r s r c @ sÌ e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z dd Z
dd Z dd Z dd Z
dd Zdd Zdd Zd d Zd d Zd!d" Zd#d$ Zd%d& Zd'd( Zd)d* Zd+d, Zd-d. Zd/d0 Zd1S )2ÚTestEventTypesc C sF ddl m} |ddd}| |jd¡ | |jd¡ | |jd¡ d S )Nr ©ÚProcessLogEventr r r )Úsupervisor.eventsr1 r ÚprocessÚpidÚdata)r r1 Úinstr r r Ú test_ProcessLogEvent_attributesD s
z.TestEventTypes.test_ProcessLogEvent_attributesc C s, ddl m} ddl m} | t||¡ d S )Nr r0 ©ÚEvent)r2 r1 r9 Ú
assertTrueÚ
issubclass)r r1 r9 r r r Ú test_ProcessLogEvent_inheritenceK s
ÿz/TestEventTypes.test_ProcessLogEvent_inheritencec C sT ddl m} |ddd}| |jd¡ | |jd¡ | |jd¡ | |jd¡ d S )Nr ©ÚProcessLogStdoutEventr r r Ústdout)r2 r> r r3 r4 r5 Úchannel)r r> r6 r r r Ú%test_ProcessLogStdoutEvent_attributesR s z4TestEventTypes.test_ProcessLogStdoutEvent_attributesc C s, ddl m} ddl m} | t||¡ d S )Nr r= r0 )r2 r> r1 r: r; )r r> r1 r r r Ú&test_ProcessLogStdoutEvent_inheritenceZ s
ÿz5TestEventTypes.test_ProcessLogStdoutEvent_inheritencec C sT ddl m} |ddd}| |jd¡ | |jd¡ | |jd¡ | |jd¡ d S )Nr ©ÚProcessLogStderrEventr r r Ústderr)r2 rD r r3 r4 r5 r@ )r rD r6 r r r Ú%test_ProcessLogStderrEvent_attributesa s z4TestEventTypes.test_ProcessLogStderrEvent_attributesc C s, ddl m} ddl m} | t||¡ d S )Nr rC r0 )r2 rD r1 r: r; )r rD r1 r r r Ú&test_ProcessLogStderrEvent_inheritencei s
ÿz5TestEventTypes.test_ProcessLogStderrEvent_inheritencec C sF ddl m} |ddd}| |jd¡ | |jd¡ | |jd¡ d S )Nr ©ÚProcessCommunicationEventr r r )r2 rI r r3 r4 r5 )r rI r6 r r r Ú)test_ProcessCommunicationEvent_attributesp s
z8TestEventTypes.test_ProcessCommunicationEvent_attributesc C s, ddl m} ddl m} | t||¡ d S )Nr rH r8 )r2 rI r9 r: r; )r rI r9 r r r Ú*test_ProcessCommunicationEvent_inheritencew s
ÿz9TestEventTypes.test_ProcessCommunicationEvent_inheritencec C sT ddl m} |ddd}| |jd¡ | |jd¡ | |jd¡ | |jd¡ d S )Nr ©Ú ProcessCommunicationStdoutEventr r r r? )r2 rM r r3 r4 r5 r@ )r rM r6 r r r Ú/test_ProcessCommunicationStdoutEvent_attributes~ s z>TestEventTypes.test_ProcessCommunicationStdoutEvent_attributesc C s, ddl m} ddl m} | t||¡ d S )Nr rL rH )r2 rM rI r: r; )r rM rI r r r Ú0test_ProcessCommunicationStdoutEvent_inheritence s ÿÿz?TestEventTypes.test_ProcessCommunicationStdoutEvent_inheritencec C sT ddl m} |ddd}| |jd¡ | |jd¡ | |jd¡ | |jd¡ d S )Nr ©Ú ProcessCommunicationStderrEventr r r rE )r2 rQ r r3 r4 r5 r@ )r rQ r6 r r r Ú/test_ProcessCommunicationStderrEvent_attributes s z>TestEventTypes.test_ProcessCommunicationStderrEvent_attributesc C s, ddl m} ddl m} | t||¡ d S )Nr rP rH )r2 rQ rI r: r; )r rQ rI r r r Ú0test_ProcessCommunicationStderrEvent_inheritence s ÿÿz?TestEventTypes.test_ProcessCommunicationStderrEvent_inheritencec C s6 ddl m} |dd}| |jd¡ | |jd¡ d S )Nr ©ÚRemoteCommunicationEventr r )r2 rU r Útyper5 )r rU r6 r r r Ú(test_RemoteCommunicationEvent_attributes s
z7TestEventTypes.test_RemoteCommunicationEvent_attributesc C s, ddl m} ddl m} | t||¡ d S )Nr rT r8 )r2 rU r9 r: r; )r rU r9 r r r Ú)test_RemoteCommunicationEvent_inheritence¤ s
ÿz8TestEventTypes.test_RemoteCommunicationEvent_inheritencec C sX ddl m} t }t|ddd}t|}t }|||}| |j|¡ | |j|¡ d S )Nr ©ÚEventRejectedEventÚprocess1ú
/bin/process1) r2 rZ r r r r r r3 r )r rZ ÚoptionsÚpconfig1r3 Zrejected_eventr r r r Ú"test_EventRejectedEvent_attributes« s
z1TestEventTypes.test_EventRejectedEvent_attributesc C s, ddl m} ddl m} | t||¡ d S )Nr rY r8 )r2 rZ r9 Ú assertFalser; )r rZ r9 r r r Ú3test_EventRejectedEvent_does_not_inherit_from_eventµ s
ÿzBTestEventTypes.test_EventRejectedEvent_does_not_inherit_from_eventc C s0 ddl m} |j|j|jfD ]}| |¡ q d S r )r r ÚSupervisorStateChangeEventÚSupervisorRunningEventZSupervisorStoppingEventÚ$_test_one_SupervisorStateChangeEvent©r r Úklassr r r Ú$test_all_SupervisorStateChangeEvents¼ s ýz3TestEventTypes.test_all_SupervisorStateChangeEventsc C s ddl m} | t||¡ d S )Nr )rb )r2 rb r: r; )r rf rb r r r rd Å s z3TestEventTypes._test_one_SupervisorStateChangeEventc C sH ddl m} |j|j|j|j|j|j|j|j |j
f D ]}| |¡ q4d S r ) r r ÚProcessStateEventÚProcessStateStoppedEventÚProcessStateExitedEventÚProcessStateFatalEventÚProcessStateBackoffEventÚProcessStateRunningEventÚProcessStateUnknownEventÚProcessStateStoppingEventÚProcessStateStartingEventÚ_test_one_ProcessStateEventre r r r Útest_all_ProcessStateEventsÉ s ÷ z*TestEventTypes.test_all_ProcessStateEventsc C s ddl m} ddlm} | t||¡ t }t|ddd}t|}|||j }|
|j |¡ |
|j |j ¡ |
|j
d¡ d S )Nr ©Ú
ProcessStates)rh r[ r\ T)Úsupervisor.statesrt r2 rh r: r; r r r ÚSTARTINGr r3 Ú
from_stateÚexpected)r rf rt rh r] r^ r3 r6 r r r rq Ø s z*TestEventTypes._test_one_ProcessStateEventc C s4 ddl m} |j|j|j|jfD ]}| |¡ q d S r )r r Ú TickEventÚ
Tick5EventÚ Tick60EventÚ
Tick3600EventÚ_test_one_TickEventre r r r Útest_all_TickEventsä s üz"TestEventTypes.test_all_TickEventsc C sF ddl m} | t||¡ |dd}| |jd¡ | |jd¡ d S )Nr )ry r r )r2 ry r: r; r ÚwhenZ supervisord)r rf ry r6 r r r r} î s
z"TestEventTypes._test_one_TickEventc C s& ddl m} |d}| |jd¡ d S )Nr ©ÚProcessGroupAddedEventÚ myprocess)r2 r r Úgroup)r r r6 r r r Ú&test_ProcessGroupAddedEvent_attributesö s z5TestEventTypes.test_ProcessGroupAddedEvent_attributesc C s& ddl m} |d}| |jd¡ d S )Nr ©ÚProcessGroupRemovedEventr )r2 r r r )r r r6 r r r Ú(test_ProcessGroupRemovedEvent_attributesû s z7TestEventTypes.test_ProcessGroupRemovedEvent_attributesN)r( r) r* r7 r< rA rB rF rG rJ rK rN rO rR rS rW rX r_ ra rg rd rr rq r~ r} r r r r r r r/ C s0
r/ c @ s e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z dd Z
dd Z dd Z dd Z
dd Zdd Zdd Zd d Zd S ) ÚTestSerializationsc C sv | d¡}|d }d}i }t|dkr.|d }|rnztdd | ¡ D }W n tk
rl td| Y nX ||fS )NÚ
r Ú r c S s g | ]}| d d¡qS )ú:r )Úsplit)Ú.0Úxr r r Ú
<listcomp>
s z3TestSerializations._deserialize.<locals>.<listcomp>z'headerdata %r could not be deserialized)r ÚlenÚdictÚ
ValueErrorÚAssertionError)r Z
serializationr5 Z
headerdataÚpayloadÚheadersr r r Ú _deserialize s
ÿ ÿ z TestSerializations._deserializec s¤ t }t|ddd t }ddlm} G fddd}||_||dd}| | ¡ ¡\}}| |d d|¡ | |d
d|¡ | |d d |¡ | |d¡ d S )
Nr[ r\ r r= c s e Zd Z ZdS )z=TestSerializations.test_plog_stdout_event.<locals>.DummyGroupN©r( r) r* Zconfigr ©r^ r r Ú
DummyGroup s r r ÚyoÚ processnameÚ groupnamer4 Ú1) r r r r2 r> r r r r )r r] r[ r> r r r r r r r Útest_plog_stdout_event s z)TestSerializations.test_plog_stdout_eventc s¤ t }t|ddd t }ddlm} G fddd}||_||dd}| | ¡ ¡\}}| |d d|¡ | |d
d|¡ | |d d |¡ | |d¡ d S )
Nr[ r\ r rC c s e Zd Z ZdS )z=TestSerializations.test_plog_stderr_event.<locals>.DummyGroupNr r r r r r % s r r r r r r4 r ) r r r r2 rD r r r r )r r] r[ rD r r r r r r r Útest_plog_stderr_event s z)TestSerializations.test_plog_stderr_eventc s¤ t }t|ddd t }ddlm} G fddd}||_||dd}| | ¡ ¡\}}| |d d|¡ | |d
d|¡ | |d d |¡ | |d¡ d S )
Nr[ r\ r rL c s e Zd Z ZdS )z>TestSerializations.test_pcomm_stdout_event.<locals>.DummyGroupNr r r r r r 4 s r r r r r r4 r ) r r r r2 rM r r r r )r r] r[ rM r r r r r r r Útest_pcomm_stdout_event/ s z*TestSerializations.test_pcomm_stdout_eventc s¤ t }t|ddd t }G fddd}||_ddlm} ||dd}| | ¡ ¡\}}| |d d|¡ | |d
d|¡ | |d d |¡ | |d¡ d S )
Nr[ r\ c s e Zd Z ZdS )z>TestSerializations.test_pcomm_stderr_event.<locals>.DummyGroupNr r r r r r B s r r rP r r r r r4 r ) r r r r r2 rQ r r r )r r] r[ r rQ r r r r r r Útest_pcomm_stderr_event> s z*TestSerializations.test_pcomm_stderr_eventc C sJ ddl m} |dd}| | ¡ ¡\}}| |d d|¡ | |d¡ d S )Nr rT ÚfooZbarrV )r2 rU r r r )r rU r r r r r r Útest_remote_comm_eventM s
z)TestSerializations.test_remote_comm_eventc C sF ddl m} |d}| | ¡ ¡\}}| |d d¡ | |d¡ d S )Nr r r¢ r r )r2 r r r r )r r r r r r r r Ú test_process_group_added_eventT s
z1TestSerializations.test_process_group_added_eventc C sF ddl m} |d}| | ¡ ¡\}}| |d d¡ | |d¡ d S )Nr r
r¢ r r )r2 r r r r )r r r r r r r r Ú test_process_group_removed_event[ s
z3TestSerializations.test_process_group_removed_eventc
sÌ ddl m} ddlm} |j|jfD ]¢}t }t|ddd G fddd}t }||_ |||j
}| | ¡ ¡\}} |
t|d¡ |
|d d¡ |
|d
d¡ |
|d d ¡ |
| d
¡ q$d S )Nr rs r r[ r\ c s e Zd Z ZdS )zUTestSerializations.test_process_state_events_without_extra_values.<locals>.DummyGroupNr r r r r r l s r r r r rw rv r )ru rt r r rk rn r r r r rv r r r r ©
r rt r rf r] r r[ r r r r r r Ú.test_process_state_events_without_extra_valuesb s& þÿ zATestSerializations.test_process_state_events_without_extra_valuesc
sæ ddl m} ddlm} |j|j|jfD ]¸}t }t|ddd G fddd}t }||_
d|_ |||j }|
| ¡ ¡\}} | t|d ¡ | |d
d¡ | |d d¡ | |d d
¡ | |d d¡ | | d¡ q(d S )Nr rs r r[ r\ c s e Zd Z ZdS )zITestSerializations.test_process_state_events_with_pid.<locals>.DummyGroupNr r r r r r s r r é r r rw rv r4 r r )ru rt r r rm ri ro r r r r r4 rv r r r r r¦ r r r Ú"test_process_state_events_with_pidx s, ýÿ z5TestSerializations.test_process_state_events_with_pidc
sF ddl m} ddlm} |j|jfD ]}t }t|ddd G fddd}t }||_ |||j
}| | ¡ ¡\}} |
t|d¡ |
|d d¡ |
|d
d¡ |
|d d ¡ |
|d
d¡ |
| d¡ d|_|||j
}| | ¡ ¡\}} |
|d
d¡ d|_|||j
}| | ¡ ¡\}} |
|d
d¡ q$d S )Nr rs r r[ r\ c s e Zd Z ZdS )zUTestSerializations.test_process_state_events_starting_and_backoff.<locals>.DummyGroupNr r r r r r s r r¨ r r rw rv ZtriesÚ0r r r r Ú2)ru rt r r rp rl r r r r rv r r r r Zbackoffr¦ r r r Ú.test_process_state_events_starting_and_backoff s8 þ
ÿ zATestSerializations.test_process_state_events_starting_and_backoffc sæ ddl m} ddlm} t }t|ddd t }G fddd}||_d|_|j ||j
d d
}| | ¡ ¡\}}|
t|d ¡ |
|d d¡ |
|d
d¡ |
|d d¡ |
|d d¡ |
|d d¡ |
|d¡ d S )Nr r rs r[ r\ c s e Zd Z ZdS )zOTestSerializations.test_process_state_exited_event_expected.<locals>.DummyGroupNr r r r r r ¶ s r r T©rx é r r r4 r rw rv rx r ©r r ru rt r r r r r4 rj rv r r r r © r r rt r] r[ r r r r r r r Ú(test_process_state_exited_event_expected° s( þz;TestSerializations.test_process_state_exited_event_expectedc sæ ddl m} ddlm} t }t|ddd t }G fddd}||_d|_|j ||j
d d
}| | ¡ ¡\}}|
t|d ¡ |
|d d¡ |
|d
d¡ |
|d d¡ |
|d d¡ |
|d d¡ |
|d¡ d S )Nr r rs r[ r\ c s e Zd Z ZdS )zQTestSerializations.test_process_state_exited_event_unexpected.<locals>.DummyGroupNr r r r r r Ì s r r Fr r® r r r4 r rw rv rx rª r r¯ r° r r r Ú*test_process_state_exited_event_unexpectedÆ s( þz=TestSerializations.test_process_state_exited_event_unexpectedc C sB ddl m} | ¡ }| | ¡ ¡\}}| |i ¡ | |d¡ d S )Nr r r )r r rc r r r )r r r r r r r r Útest_supervisor_sc_eventÜ s
z+TestSerializations.test_supervisor_sc_eventc C s^ ddl m} |j|j|jfD ]<}|dd}| | ¡ ¡\}}| |ddi¡ | |d¡ q d S )Nr r r r r r r )r r rz r{ r| r r r )r r rf r r r r r r Útest_tick_eventsã s ý
z#TestSerializations.test_tick_eventsN)r( r) r* r r r r r¡ r£ r¤ r¥ r§ r© r¬ r± r² r³ r´ r r r r r s r c @ s e Zd Zdd Zdd ZdS )ÚTestUtilityFunctionsc C s8 ddl m} |jj ¡ D ]\}}| | |¡|¡ qd S r )r r Ú
EventTypesÚ__dict__Úitemsr ZgetEventNameByType)r r ÚnameÚvaluer r r Útest_getEventNameByTypeð s z,TestUtilityFunctions.test_getEventNameByTypec C s` ddl m} | t|jd¡ G dd d|j}z"| d|¡ | |jj|k¡ W 5 |j`X d S )Nr r ÚFOOc @ s e Zd ZdS )z4TestUtilityFunctions.test_register.<locals>.FooEventNr' r r r r ÚFooEventø s r½ ) r r r` Úhasattrr¶ r9 r¼ Úregisterr: )r r r½ r r r Ú
test_registerõ s z"TestUtilityFunctions.test_registerN)r( r) r* r» rÀ r r r r rµ ï s rµ c C s t tjt ¡S )N)ÚunittestZ
findTestCasesÚsysÚmodulesr( r r r r Ú
test_suite s rÄ Ú__main__)Z defaultTest)r rÁ Zsupervisor.tests.baser r r r ZTestCaser r/ r rµ rÄ r( Úmainr r r r Ú<module> s : > p