@@ -218,7 +218,6 @@ protected async IAsyncEnumerable<DenseTensor<float>> DiffuseVideoAsync(IDiffuser
218218
219219 var frameIndex = 0 ;
220220 var videoFrames = promptOptions . InputVideo . Frames ;
221- var schedulerFrameCallback = CreateBatchCallback ( progressCallback , videoFrames . Count , ( ) => frameIndex ) ;
222221 foreach ( var videoFrame in videoFrames )
223222 {
224223 if ( promptOptions . DiffuserType == DiffuserType . ControlNet || promptOptions . DiffuserType == DiffuserType . ControlNetImage )
@@ -234,7 +233,7 @@ protected async IAsyncEnumerable<DenseTensor<float>> DiffuseVideoAsync(IDiffuser
234233 promptOptions . InputImage = videoFrame ;
235234 }
236235
237- var frameResultTensor = await diffuser . DiffuseAsync ( promptOptions , schedulerOptions , promptEmbeddings , performGuidance , schedulerFrameCallback , cancellationToken ) ;
236+ var frameResultTensor = await diffuser . DiffuseAsync ( promptOptions , schedulerOptions , promptEmbeddings , performGuidance , progressCallback , cancellationToken ) ;
238237
239238 // Frame Progress
240239 ReportBatchProgress ( progressCallback , ++ frameIndex , videoFrames . Count , frameResultTensor ) ;
@@ -296,7 +295,9 @@ protected Action<DiffusionProgress> CreateBatchCallback(Action<DiffusionProgress
296295 StepValue = progress . StepValue ,
297296 StepTensor = progress . StepTensor ,
298297 BatchMax = batchCount ,
299- BatchValue = batchIndex ( )
298+ BatchValue = batchIndex ( ) ,
299+ BatchTensor = progress . BatchTensor ,
300+ Message = progress . Message
300301 } ) ;
301302 }
302303
0 commit comments