diff --git a/src/plugins/IORedisPlugin.ts b/src/plugins/IORedisPlugin.ts index adbd930..626606c 100644 --- a/src/plugins/IORedisPlugin.ts +++ b/src/plugins/IORedisPlugin.ts @@ -52,9 +52,17 @@ class IORedisPlugin implements SwPlugin { span.tag(Tag.dbType('Redis')); span.tag(Tag.dbInstance(`${this.condition.select}`)); - const ret = wrapPromise(span, _original.apply(this, args)); - span.async(); - return ret; + try { + const ret = wrapPromise(span, _original.apply(this, args)); + span.async(); + return ret; + + } catch (err) { + span.error(err); + span.stop(); + + throw err; + } } } }