fix bug in prev commit

This commit is contained in:
Dave Horton
2023-05-08 13:50:37 -04:00
parent 1b91e8d0a0
commit 843ae6c440

View File

@@ -782,11 +782,11 @@ class CallSession extends Emitter {
} }
if (0 === this.tasks.length && this.requestor instanceof WsRequestor && !this.callGone) { if (0 === this.tasks.length && this.requestor instanceof WsRequestor && !this.callGone) {
let span; //let span;
try { try {
//const {span} = this.rootSpan.startChildSpan('waiting for commands');
//const {reason, queue, command} = await this._awaitCommandsOrHangup();
/* /*
const {span} = this.rootSpan.startChildSpan('waiting for commands');
const {reason, queue, command} = await this._awaitCommandsOrHangup();
span.setAttributes({ span.setAttributes({
'completion.reason': reason, 'completion.reason': reason,
'async.request.queue': queue, 'async.request.queue': queue,
@@ -794,9 +794,10 @@ class CallSession extends Emitter {
}); });
span.end(); span.end();
*/ */
await this._awaitCommandsOrHangup();
if (this.callGone) break; if (this.callGone) break;
} catch (err) { } catch (err) {
span.end(); //span.end();
this.logger.info(err, 'CallSession:exec - error waiting for new commands'); this.logger.info(err, 'CallSession:exec - error waiting for new commands');
break; break;
} }