mirror of
https://github.com/MindWorkAI/AI-Studio.git
synced 2026-08-11 17:52:10 +00:00
Preserve queued files on batch cancellation
This commit is contained in:
parent
d13215c5b3
commit
e9e394ed96
@ -107,11 +107,7 @@ public partial class AssistantBatchProcessing
|
|||||||
// remaining files keep their QUEUED state on purpose, so
|
// remaining files keep their QUEUED state on purpose, so
|
||||||
// that the UI shows which files were not processed:
|
// that the UI shows which files were not processed:
|
||||||
if (token.IsCancellationRequested)
|
if (token.IsCancellationRequested)
|
||||||
{
|
break;
|
||||||
fileResult.Status = BatchProcessingFileStatus.CANCELED;
|
|
||||||
fileResult.Message = T("The batch run was canceled.");
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
fileResult.Status = BatchProcessingFileStatus.PROCESSING;
|
fileResult.Status = BatchProcessingFileStatus.PROCESSING;
|
||||||
fileResult.ModelName = this.ProviderSettings.Model.ToString();
|
fileResult.ModelName = this.ProviderSettings.Model.ToString();
|
||||||
@ -132,14 +128,16 @@ public partial class AssistantBatchProcessing
|
|||||||
var doneFiles = this.fileResults.Count(fileResult => fileResult.Status is BatchProcessingFileStatus.DONE);
|
var doneFiles = this.fileResults.Count(fileResult => fileResult.Status is BatchProcessingFileStatus.DONE);
|
||||||
var failedFiles = this.fileResults.Count(fileResult => fileResult.Status is BatchProcessingFileStatus.FAILED);
|
var failedFiles = this.fileResults.Count(fileResult => fileResult.Status is BatchProcessingFileStatus.FAILED);
|
||||||
var canceledFiles = this.fileResults.Count(fileResult => fileResult.Status is BatchProcessingFileStatus.CANCELED);
|
var canceledFiles = this.fileResults.Count(fileResult => fileResult.Status is BatchProcessingFileStatus.CANCELED);
|
||||||
|
var queuedFiles = this.fileResults.Count(fileResult => fileResult.Status is BatchProcessingFileStatus.QUEUED);
|
||||||
|
|
||||||
this.Logger.LogInformation(
|
this.Logger.LogInformation(
|
||||||
"Batch processing finished after {ElapsedMilliseconds} ms. TotalFiles={TotalFiles}, DoneFiles={DoneFiles}, FailedFiles={FailedFiles}, CanceledFiles={CanceledFiles}, OutputWriteFailed={OutputWriteFailed}.",
|
"Batch processing finished after {ElapsedMilliseconds} ms. TotalFiles={TotalFiles}, DoneFiles={DoneFiles}, FailedFiles={FailedFiles}, CanceledFiles={CanceledFiles}, QueuedFiles={QueuedFiles}, OutputWriteFailed={OutputWriteFailed}.",
|
||||||
stopwatch.ElapsedMilliseconds,
|
stopwatch.ElapsedMilliseconds,
|
||||||
this.fileResults.Count,
|
this.fileResults.Count,
|
||||||
doneFiles,
|
doneFiles,
|
||||||
failedFiles,
|
failedFiles,
|
||||||
canceledFiles,
|
canceledFiles,
|
||||||
|
queuedFiles,
|
||||||
this.hasReportedWriteFailure);
|
this.hasReportedWriteFailure);
|
||||||
|
|
||||||
// The cancellation token source belongs to the base class, which
|
// The cancellation token source belongs to the base class, which
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user