def METHOD_NAME(self, client_info):
    # Precompute the wrapped methods.
    self._wrapped_methods = {
        self.run_pipeline: gapic_v1.method.wrap_method(
            self.run_pipeline,
            default_retry=retries.Retry(
                initial=0.1,
                maximum=60.0,
                multiplier=1.3,
                predicate=retries.if_exception_type(
                    core_exceptions.DeadlineExceeded,
                    core_exceptions.ServiceUnavailable,
                ),
                deadline=120.0,
            ),
            default_timeout=120.0,
            client_info=client_info,
        ),
    }