(self, bucket_name, min_successes=3)
| 643 | return response['Body'].read().decode('utf-8') |
| 644 | |
| 645 | def wait_bucket_exists(self, bucket_name, min_successes=3): |
| 646 | client = self._create_client_for_bucket(bucket_name) |
| 647 | waiter = client.get_waiter('bucket_exists') |
| 648 | consistency_waiter = ConsistencyWaiter( |
| 649 | min_successes=min_successes, delay_initial_poll=True |
| 650 | ) |
| 651 | consistency_waiter.wait( |
| 652 | lambda: waiter.wait(Bucket=bucket_name) is None |
| 653 | ) |
| 654 | |
| 655 | def bucket_not_exists(self, bucket_name): |
| 656 | client = self._create_client_for_bucket(bucket_name) |
no test coverage detected