'Run the test flow.'

def RunTest(self, test_name):

    cls = base.AutomatedTest.classes[test_name]
    test_object = cls(client_id=self.client_id, platform=self.state.client_summary.system_info.system, token=self.token, local_worker=False)
    self.Log('Running    %s    on    %s    (%s:    %s,    %s,    %s)', test_object.__class__.__name__, self.client_id, self.state.client_summary.system_info.fqdn, self.state.client_summary.system_info.system, self.state.client_summary.system_info.version, self.state.client_summary.system_info.machine)
    test_object.setUp()
    session_id = self.CallFlow(test_object.flow, next_state='ProcessResults', write_intermediate_results=True, **test_object.args)
    self.state.flow_test_map[session_id] = test_name
