Comparing version 0.0.11 to 0.0.12
@@ -89,5 +89,5 @@ 'use strict' | ||
try { | ||
await task.recover(err) | ||
await task.rollback(err) | ||
} catch (err) { | ||
error(`Error during recover process %O`, err) | ||
error(`Error during rollback process %O`, err) | ||
} | ||
@@ -94,0 +94,0 @@ } |
@@ -44,12 +44,12 @@ 'use strict' | ||
debug( | ||
'Task <%s> execute recover routines cause (Job) error', | ||
'Task <%s> execute rollback routines cause (Job) error', | ||
this.parentTask.name | ||
) | ||
// avoid error bubbling otherwise we recover a second time | ||
// avoid error bubbling otherwise we rollback a second time | ||
try { | ||
await this.pipeline.recover(err) | ||
await this.pipeline.rollback(err) | ||
} catch (err) { | ||
error( | ||
'Task <%s> error during (Job) recover routine', | ||
'Task <%s> error during (Job) rollback routine', | ||
this.parentTask.name | ||
@@ -56,0 +56,0 @@ ) |
@@ -166,4 +166,4 @@ 'use strict' | ||
*/ | ||
async recover(err) { | ||
debug(`Task <${this.name}> execute recover routines`) | ||
async rollback(err) { | ||
debug(`Task <${this.name}> execute rollback routines`) | ||
@@ -170,0 +170,0 @@ for (let hook of this.onError) { |
{ | ||
"name": "bootme", | ||
"version": "0.0.11", | ||
"version": "0.0.12", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
11608