def _prep_wrapped_messages(self, client_info):
    self._wrapped_methods = {self.create_dataset: gapic_v1.method.wrap_method(self.create_dataset, default_timeout=30.0, client_info=client_info), self.get_dataset: gapic_v1.method.wrap_method(self.get_dataset, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.list_datasets: gapic_v1.method.wrap_method(self.list_datasets, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.delete_dataset: gapic_v1.method.wrap_method(self.delete_dataset, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.import_data: gapic_v1.method.wrap_method(self.import_data, default_timeout=30.0, client_info=client_info), self.export_data: gapic_v1.method.wrap_method(self.export_data, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.get_data_item: gapic_v1.method.wrap_method(self.get_data_item, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.list_data_items: gapic_v1.method.wrap_method(self.list_data_items, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.get_annotated_dataset: gapic_v1.method.wrap_method(self.get_annotated_dataset, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.list_annotated_datasets: gapic_v1.method.wrap_method(self.list_annotated_datasets, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.delete_annotated_dataset: gapic_v1.method.wrap_method(self.delete_annotated_dataset, default_timeout=None, client_info=client_info), self.label_image: gapic_v1.method.wrap_method(self.label_image, default_timeout=30.0, client_info=client_info), self.label_video: gapic_v1.method.wrap_method(self.label_video, default_timeout=30.0, client_info=client_info), self.label_text: gapic_v1.method.wrap_method(self.label_text, default_timeout=30.0, client_info=client_info), self.get_example: gapic_v1.method.wrap_method(self.get_example, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.list_examples: gapic_v1.method.wrap_method(self.list_examples, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.create_annotation_spec_set: gapic_v1.method.wrap_method(self.create_annotation_spec_set, default_timeout=30.0, client_info=client_info), self.get_annotation_spec_set: gapic_v1.method.wrap_method(self.get_annotation_spec_set, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.list_annotation_spec_sets: gapic_v1.method.wrap_method(self.list_annotation_spec_sets, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.delete_annotation_spec_set: gapic_v1.method.wrap_method(self.delete_annotation_spec_set, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.create_instruction: gapic_v1.method.wrap_method(self.create_instruction, default_timeout=30.0, client_info=client_info), self.get_instruction: gapic_v1.method.wrap_method(self.get_instruction, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.list_instructions: gapic_v1.method.wrap_method(self.list_instructions, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.delete_instruction: gapic_v1.method.wrap_method(self.delete_instruction, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.get_evaluation: gapic_v1.method.wrap_method(self.get_evaluation, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.search_evaluations: gapic_v1.method.wrap_method(self.search_evaluations, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.search_example_comparisons: gapic_v1.method.wrap_method(self.search_example_comparisons, default_timeout=30.0, client_info=client_info), self.create_evaluation_job: gapic_v1.method.wrap_method(self.create_evaluation_job, default_timeout=30.0, client_info=client_info), self.update_evaluation_job: gapic_v1.method.wrap_method(self.update_evaluation_job, default_timeout=30.0, client_info=client_info), self.get_evaluation_job: gapic_v1.method.wrap_method(self.get_evaluation_job, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.pause_evaluation_job: gapic_v1.method.wrap_method(self.pause_evaluation_job, default_timeout=30.0, client_info=client_info), self.resume_evaluation_job: gapic_v1.method.wrap_method(self.resume_evaluation_job, default_timeout=30.0, client_info=client_info), self.delete_evaluation_job: gapic_v1.method.wrap_method(self.delete_evaluation_job, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.list_evaluation_jobs: gapic_v1.method.wrap_method(self.list_evaluation_jobs, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info)}
def _prep_wrapped_messages(self, client_info):
    self._wrapped_methods = {self.create_dataset: gapic_v1.method.wrap_method(self.create_dataset, default_timeout=30.0, client_info=client_info), self.get_dataset: gapic_v1.method.wrap_method(self.get_dataset, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.list_datasets: gapic_v1.method.wrap_method(self.list_datasets, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.delete_dataset: gapic_v1.method.wrap_method(self.delete_dataset, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.import_data: gapic_v1.method.wrap_method(self.import_data, default_timeout=30.0, client_info=client_info), self.export_data: gapic_v1.method.wrap_method(self.export_data, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.get_data_item: gapic_v1.method.wrap_method(self.get_data_item, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.list_data_items: gapic_v1.method.wrap_method(self.list_data_items, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.get_annotated_dataset: gapic_v1.method.wrap_method(self.get_annotated_dataset, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.list_annotated_datasets: gapic_v1.method.wrap_method(self.list_annotated_datasets, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.delete_annotated_dataset: gapic_v1.method.wrap_method(self.delete_annotated_dataset, default_timeout=None, client_info=client_info), self.label_image: gapic_v1.method.wrap_method(self.label_image, default_timeout=30.0, client_info=client_info), self.label_video: gapic_v1.method.wrap_method(self.label_video, default_timeout=30.0, client_info=client_info), self.label_text: gapic_v1.method.wrap_method(self.label_text, default_timeout=30.0, client_info=client_info), self.get_example: gapic_v1.method.wrap_method(self.get_example, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.list_examples: gapic_v1.method.wrap_method(self.list_examples, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.create_annotation_spec_set: gapic_v1.method.wrap_method(self.create_annotation_spec_set, default_timeout=30.0, client_info=client_info), self.get_annotation_spec_set: gapic_v1.method.wrap_method(self.get_annotation_spec_set, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.list_annotation_spec_sets: gapic_v1.method.wrap_method(self.list_annotation_spec_sets, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.delete_annotation_spec_set: gapic_v1.method.wrap_method(self.delete_annotation_spec_set, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.create_instruction: gapic_v1.method.wrap_method(self.create_instruction, default_timeout=30.0, client_info=client_info), self.get_instruction: gapic_v1.method.wrap_method(self.get_instruction, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.list_instructions: gapic_v1.method.wrap_method(self.list_instructions, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.delete_instruction: gapic_v1.method.wrap_method(self.delete_instruction, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.get_evaluation: gapic_v1.method.wrap_method(self.get_evaluation, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.search_evaluations: gapic_v1.method.wrap_method(self.search_evaluations, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.search_example_comparisons: gapic_v1.method.wrap_method(self.search_example_comparisons, default_timeout=30.0, client_info=client_info), self.create_evaluation_job: gapic_v1.method.wrap_method(self.create_evaluation_job, default_timeout=30.0, client_info=client_info), self.update_evaluation_job: gapic_v1.method.wrap_method(self.update_evaluation_job, default_timeout=30.0, client_info=client_info), self.get_evaluation_job: gapic_v1.method.wrap_method(self.get_evaluation_job, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.pause_evaluation_job: gapic_v1.method.wrap_method(self.pause_evaluation_job, default_timeout=30.0, client_info=client_info), self.resume_evaluation_job: gapic_v1.method.wrap_method(self.resume_evaluation_job, default_timeout=30.0, client_info=client_info), self.delete_evaluation_job: gapic_v1.method.wrap_method(self.delete_evaluation_job, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info), self.list_evaluation_jobs: gapic_v1.method.wrap_method(self.list_evaluation_jobs, default_retry=retries.Retry(initial=0.1, maximum=30.0, multiplier=1.3, predicate=retries.if_exception_type(core_exceptions.DeadlineExceeded, core_exceptions.ServiceUnavailable), deadline=30.0), default_timeout=30.0, client_info=client_info)}