End spans even on dataStream retry

Author: odeke-em

src/database.ts

@@ -3563,12 +3563,8 @@ class Database extends common.GrpcServiceObject {
                   mutationGroups,
                   options
                 );
-                dataStream.once('end', () => span.end());
-                dataStream.once('error', err => {
-                  setSpanError(span, err!);
-                  span.end();
-                });
                 dataStream.pipe(proxyStream);
+                span.end();
               } else {
                 span.end();
                 proxyStream.destroy(err);

src/transaction.ts

@@ -465,7 +465,6 @@ export class Snapshot extends EventEmitter {
           } else {
             this._update(resp);
           }
-
           span.end();
           callback!(err, resp);
         }