This commit is contained in:
@@ -369,7 +369,7 @@ namespace AyaNova.Biz
|
||||
private async Task ProcessBulkJobAsync(OpsJob job)
|
||||
{
|
||||
await JobsBiz.UpdateJobStatusAsync(job.GId, JobStatus.Running);
|
||||
await JobsBiz.LogJobAsync(job.GId, $"Batch job {job.SubType} started...");
|
||||
await JobsBiz.LogJobAsync(job.GId, $"LT:StartJob {job.SubType}");
|
||||
List<long> idList = new List<long>();
|
||||
long ProcessedObjectCount = 0;
|
||||
long FailedObjectCount = 0;
|
||||
@@ -402,7 +402,7 @@ namespace AyaNova.Biz
|
||||
case JobSubType.Delete:
|
||||
if (!await DeleteAsync(id))
|
||||
{
|
||||
await JobsBiz.LogJobAsync(job.GId, $"LT:Errors id({id}): {GetErrorsAsString()}");
|
||||
await JobsBiz.LogJobAsync(job.GId, $"LT:Errors {GetErrorsAsString()} id({id})");
|
||||
FailedObjectCount++;
|
||||
}
|
||||
break;
|
||||
@@ -413,7 +413,7 @@ namespace AyaNova.Biz
|
||||
{
|
||||
o = await PutAsync(o);
|
||||
if (o == null)
|
||||
await JobsBiz.LogJobAsync(job.GId, $"LT:Errors id({id}): {GetErrorsAsString()}");
|
||||
await JobsBiz.LogJobAsync(job.GId, $"LT:Errors {GetErrorsAsString()} id({id})");
|
||||
else
|
||||
ProcessedObjectCount++;
|
||||
}
|
||||
@@ -427,7 +427,7 @@ namespace AyaNova.Biz
|
||||
}
|
||||
}
|
||||
|
||||
await JobsBiz.LogJobAsync(job.GId, $"Batch job {job.SubType} processed {ProcessedObjectCount} of {idList.Count} with {FailedObjectCount} failures");
|
||||
await JobsBiz.LogJobAsync(job.GId, $"LT:BatchJob {job.SubType} {ProcessedObjectCount} / {idList.Count}{(FailedObjectCount > 0 ? " LT:Failed" + FailedObjectCount : "")}");
|
||||
await JobsBiz.UpdateJobStatusAsync(job.GId, FailedObjectCount == 0 ? JobStatus.Completed : JobStatus.Failed);
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user