def METHOD_NAME(self):
    for i in range(100):
        body = self.get_test_item()
        self.container.create_item(body=body)
    start_time = time.time()
    print("created items, changing offer to 22k and starting queries")
    self.database.replace_throughput(22000)
    offer_time = time.time()
    print("changed offer to 11k")
    print("--------------------------------")
    print("now starting queries")
    self.run_queries(self.container, 100)  # initial check for queries before partition split
    print("initial check succeeded, now reading offer until replacing is done")
    offer = self.database.get_throughput()
    while True:
        if time.time() - start_time > 60 * 20: #timeout test at 20 minutes
            raise CosmosClientTimeoutError()
        if offer.properties['content'].get('isOfferReplacePending', False):
            time.sleep(10)
            offer = self.database.get_throughput()
        else:
            print("offer replaced successfully, took around {} seconds".format(time.time() - offer_time))
            self.run_queries(self.container, 100)  # check queries work post partition split
            print("test over")
            self.assertTrue(offer.offer_throughput > self.throughput)
            self.client.delete_database(self.configs.TEST_THROUGHPUT_DATABASE_ID)
            return