@@ -905,25 +905,25 @@ bigtable::RowStream DataConnectionImpl::ExecuteQuery(
905905 std::unique_ptr<BackoffPolicy> backoff_policy_prototype,
906906 std::shared_ptr<OperationContext> const & operation_context) mutable
907907 -> StatusOr<std::unique_ptr<bigtable::ResultSourceInterface>> {
908- auto factory =
909- [stub, request, tracing_enabled, tracing_options, operation_context,
910- metadata](std::string const & resume_token) mutable {
911- if (!resume_token.empty ()) request.set_resume_token (resume_token);
912- auto context = std::make_shared<grpc::ClientContext>();
913- auto const & options = internal::CurrentOptions ();
914- internal::ConfigureContext (*context, options);
915- operation_context->PreCall (*context);
916- auto stream = stub->ExecuteQuery (context, options, request);
917- std::unique_ptr<PartialResultSetReader> reader =
918- std::make_unique<DefaultPartialResultSetReader>(
919- std::move (context), operation_context, std::move (stream),
920- metadata);
921- if (tracing_enabled) {
922- reader = std::make_unique<LoggingResultSetReader>(std::move (reader),
923- tracing_options);
924- }
925- return reader;
926- };
908+ auto factory = [stub, request, tracing_enabled, tracing_options,
909+ operation_context,
910+ metadata](std::string const & resume_token) mutable {
911+ if (!resume_token.empty ()) request.set_resume_token (resume_token);
912+ auto context = std::make_shared<grpc::ClientContext>();
913+ auto const & options = internal::CurrentOptions ();
914+ internal::ConfigureContext (*context, options);
915+ operation_context->PreCall (*context);
916+ auto stream = stub->ExecuteQuery (context, options, request);
917+ std::unique_ptr<PartialResultSetReader> reader =
918+ std::make_unique<DefaultPartialResultSetReader>(
919+ std::move (context), operation_context, std::move (stream),
920+ metadata);
921+ if (tracing_enabled) {
922+ reader = std::make_unique<LoggingResultSetReader>(std::move (reader),
923+ tracing_options);
924+ }
925+ return reader;
926+ };
927927
928928 auto resume = std::make_unique<PartialResultSetResume>(
929929 std::move (factory), Idempotency::kIdempotent ,
0 commit comments