DyingWorkerTestCase Class Reference

Inheritance diagram for DyingWorkerTestCase:

Public Member Functions
def	testUnregistration (self)

Static Public Attributes
list	extra_arguments = ["--exit", "--prefix", "dying_"]
	set the extra arguments we need ...

Detailed Description

Test case for dying workers

Definition at line 142 of file test_worker.py.

Member Function Documentation

testUnregistration()

def testUnregistration

(

self

)

test function

Definition at line 148 of file test_worker.py.

    def testUnregistration(self):
        """test function"""
        self.start()
 
        # lets send some events
        for _ in range(10):
            self.send(self.input_socket, "u", first_data=self.event_data, identity=self.input_identity)
            self.assertIsMsgType(self.output_socket, "w", router=True)
            self.send(self.output_socket, "c", identity=self.output_identity)
 
        self.assertHasOutputFile("dying_beginrun_called", timeout=1)
 
        # Now we kill one of the workers
        Path("dying_exit_request").touch()
 
        self.send(self.input_socket, "u", first_data=self.event_data, identity=self.input_identity)
        self.assertHasOutputFile("dying_exit_called", timeout=1)
        msg = self.assertIsMsgType(self.output_socket, "d", router=True)
        # the message content should be the worker that has died
        self.assertEqual(msg[2].decode(), self.output_identity)
        self.send(self.output_socket, "c", identity=msg[0].decode())
 
        self.assertIsDown("worker", timeout=10)
 
 

Member Data Documentation

extra_arguments

list extra_arguments = ["--exit", "--prefix", "dying_"]

static

set the extra arguments we need ...

Definition at line 146 of file test_worker.py.

---

The documentation for this class was generated from the following file:

• daq/hbasf2/tests/test_worker.py