def METHOD_NAME(self):
    # issue SHUTDOWN while traffic is generated
    indexes = range(self.client_count)
    pool = Pool(nodes=self.client_count)
    # invoke queries
    m = pool.amap(query_crud, graphs, indexes)
    # sleep for half a second, allowing threads to kick in
    sleep(0.2)
    self.env.stop()
    # wait for processes to return
    m.wait()
    self.env.assertTrue(self.env.checkExitCode())
    pool.clear()