@@ -418,7 +418,6 @@ function handleServerside(
418418 background : BackgroundCallbackInfo | undefined ,
419419 additionalArgs : [ string , string , boolean ?] [ ] | undefined ,
420420 getState : any ,
421- output : string ,
422421 running : any
423422) : Promise < CallbackResponse > {
424423 if ( hooks . request_pre ) {
@@ -572,7 +571,7 @@ function handleServerside(
572571 cacheKey : data . cacheKey as string ,
573572 cancelInputs : data . cancel ,
574573 progressDefault : data . progressDefault ,
575- output
574+ output : JSON . stringify ( payload . outputs )
576575 } ;
577576 dispatch ( addCallbackJob ( jobInfo ) ) ;
578577 job = data . job ;
@@ -791,9 +790,10 @@ export function executeCallback(
791790 let lastError : any ;
792791
793792 const additionalArgs : [ string , string , boolean ?] [ ] = [ ] ;
793+ const jsonOutput = JSON . stringify ( payload . outputs ) ;
794794 values ( getState ( ) . callbackJobs ) . forEach (
795795 ( job : CallbackJobPayload ) => {
796- if ( cb . callback . output === job . output ) {
796+ if ( jsonOutput === job . output ) {
797797 // Terminate the old jobs that are not completed
798798 // set as outdated for the callback promise to
799799 // resolve and remove after.
@@ -830,7 +830,6 @@ export function executeCallback(
830830 background ,
831831 additionalArgs . length ? additionalArgs : undefined ,
832832 getState ,
833- cb . callback . output ,
834833 cb . callback . running
835834 ) ;
836835
0 commit comments