(circuits)
prologic@daisy
Wed Mar 05 05:35:29
~/circuits
$ python test_workers.py
<registered[worker] (<Worker/worker 1371:MainThread (queued=0) [S]>, <MyWorker/* 1371:MainThread (queued=4) [R]> )>
<task[*] (<function hello_loop at 0x1574d70> )>
<registered[*] (<Debugger/* 1371:MainThread (queued=0) [S]>, <MyWorker/* 1371:MainThread (queued=2) [R]> )>
<started[*] (<MyWorker/* 1371:MainThread (queued=1) [R]> )>
Hello
Hello
Hello
^C<signal[*] (2, <frame object at 0x7fb690001540> )>
<stopped[*] (<MyWorker/* 1371:MainThread (queued=0) [S]> )>
Hello
Hello
<prepare_unregister[worker] (<Worker/worker 1371:MainThread (queued=0) [S]> )>
<prepare_unregister_complete[<Worker/worker 1371:MainThread (queued=0) [S]>] (<prepare_unregister[worker] (<Worker/worker 1371:MainThread (queued=0) [S]> )>, None )>
<task_success[*] (<task[*] (<function hello_loop at 0x1574d70> )>, None )>
<unregistered[worker] (<Worker/worker 1371:MainThread (queued=0) [S]>, <MyWorker/* 1371:MainThread (queued=0) [S]> )>