def testCallClient(self):
    flow_obj = self.FlowSetup("FlowOrderTest")

    # Check that a message went out to the client
    manager = queue_manager.QueueManager(token=self.token)
    tasks = manager.Query(self.client_id, limit=100)

    self.assertEqual(len(tasks), 1)

    message = tasks[0]

    self.assertEqual(message.session_id, flow_obj.session_id)
    self.assertEqual(message.request_id, 1)
    self.assertEqual(message.name, "Test")
Set the given properties on a service and update it.
dataset/ETHPy150Open google/grr/grr/lib/flow_test.py/FlowTest.testCallClient--crossover with--dataset/ETHPy150Open openstack/rack/rack/db/api.py/service_update