@@ -21,7 +21,7 @@ class Pipeline {
2121
2222 savePipeline ( ev , arg ) {
2323 const callback = function ( err , result ) {
24- ev . sender . send ( 'data-save-pipeline-callback' , err , result ) ;
24+ ev . sender . send ( 'data-save-pipeline-callback' , utils . serialize ( err ) , result ) ;
2525 }
2626 try {
2727 const self = this ;
@@ -61,7 +61,7 @@ class Pipeline {
6161 */
6262 clonePipeline ( ev , arg ) {
6363 const callback = function ( err , result ) {
64- ev . sender . send ( 'data-clone-pipeline-callback' , err , result ) ;
64+ ev . sender . send ( 'data-clone-pipeline-callback' , utils . serialize ( err ) , result ) ;
6565 }
6666 try {
6767 let pipelines = this . storage . getAll ( { cache : false } ) ;
@@ -94,7 +94,7 @@ class Pipeline {
9494 removePipeline ( ev , arg ) {
9595 const self = this ;
9696 const callback = function ( err , result ) {
97- ev . sender . send ( 'data-remove-pipeline-callback' , err , result ) ;
97+ ev . sender . send ( 'data-remove-pipeline-callback' , utils . serialize ( err ) , result ) ;
9898 }
9999 try {
100100 let pipelines = self . storage . getAll ( { cache : false } ) ;
@@ -150,7 +150,7 @@ class Pipeline {
150150
151151 getPipelines ( ev , arg ) {
152152 const callback = function ( err , result ) {
153- ev . sender . send ( 'data-pipelines-callback' , err , result ) ;
153+ ev . sender . send ( 'data-pipelines-callback' , utils . serialize ( err ) , result ) ;
154154 }
155155 try {
156156 let result = this . storage . getAll ( { cache : false } ) ;
@@ -170,7 +170,7 @@ class Pipeline {
170170 */
171171 getPipelineLog ( ev , arg ) {
172172 const callback = function ( err , result ) {
173- ev . sender . send ( 'data-pipeline-log-callback' , err , result ) ;
173+ ev . sender . send ( 'data-pipeline-log-callback' , utils . serialize ( err ) , result ) ;
174174 }
175175 try {
176176 let index = 1 ;
@@ -203,7 +203,7 @@ class Pipeline {
203203 runPipeline ( ev , arg ) {
204204 const self = this ;
205205 const callback = function ( err , result ) {
206- ev . sender . send ( 'pipeline-run-callback' , err , result ) ;
206+ ev . sender . send ( 'pipeline-run-callback' , utils . serialize ( err ) , result ) ;
207207 }
208208 const processing = function ( ) {
209209 ev . sender . send ( 'pipeline-run-callback' , null , { type : 'process' } ) ;
0 commit comments