change

Author: peggy-quartech

src/Spd.Manager.ScheduleJob/Contract.cs

@@ -9,7 +9,7 @@ public interface IScheduleJobManager
     }
 
     #region run schedule job session
-    public record RunScheduleJobSessionCommand(Guid JobSessionId, int ConcurrentRequests) : IRequest<Unit>;
-    public record RunMonthlyInvoiceJobCommand(Guid JobSessionId, int ConcurrentRequests) : IRequest<Unit>;
+    public record RunScheduleJobSessionCommand(Guid JobSessionId, int ConcurrentRequests = 3) : IRequest<Unit>;
+    public record RunMonthlyInvoiceJobCommand(Guid JobSessionId, int ConcurrentRequests = 3) : IRequest<Unit>;
     #endregion
 }

src/Spd.Manager.ScheduleJob/ScheduleJobManager.cs

@@ -77,7 +77,7 @@ public async Task<Unit> Handle(RunScheduleJobSessionCommand cmd, CancellationTok
         }
 
         Stopwatch stopwatch = Stopwatch.StartNew();
-        using var cts = new CancellationTokenSource(); // no timeout
+        using var cts = new CancellationTokenSource(); // no timeout, this is the resolve for mysteriously cancelled requests
         //request will from bcgov_schedulejob
         RunJobRequest request = new RunJobRequest
         {
@@ -86,7 +86,7 @@ public async Task<Unit> Handle(RunScheduleJobSessionCommand cmd, CancellationTok
             PrimaryEntityFilterStr = "statecode eq 0 and spd_eligibleforcreditpayment eq 100000001",
             PrimaryEntityIdName = "accountid"
         };
-        var result = await _generalizeScheduleJobRepository.RunJobsAsync(request, cts.Token);
+        var result = await _generalizeScheduleJobRepository.RunJobsAsync(request, cmd.ConcurrentRequests, cts.Token);
         stopwatch.Stop();
 
         //update result in JobSession

src/Spd.Resource.Repository.JobSchedule/GeneralizeScheduleJob/Contract.cs

@@ -2,7 +2,7 @@ namespace Spd.Resource.Repository.JobSchedule.GeneralizeScheduleJob
 {
     public interface IGeneralizeScheduleJobRepository
     {
-        public Task<IEnumerable<ResultResp>> RunJobsAsync(RunJobRequest request, CancellationToken cancellationToken);
+        public Task<IEnumerable<ResultResp>> RunJobsAsync(RunJobRequest request, int ConcurrentRequests, CancellationToken cancellationToken);
     }
 
     public record RunJobRequest

src/Spd.Resource.Repository.JobSchedule/GeneralizeScheduleJob/GeneralizeScheduleJobRepository.cs

@@ -75,7 +75,7 @@ public GeneralizeScheduleJobRepository(IDynamicsContextFactory ctx,
     //    return results;
     //}
 
-    public async Task<IEnumerable<ResultResp>> RunJobsAsync(RunJobRequest request, CancellationToken ct)
+    public async Task<IEnumerable<ResultResp>> RunJobsAsync(RunJobRequest request, int concurrentRequests, CancellationToken ct)
     {
         string primaryEntityName = request.PrimaryEntityName;
         string filterStr = request.PrimaryEntityFilterStr;
@@ -87,7 +87,7 @@ public async Task<IEnumerable<ResultResp>> RunJobsAsync(RunJobRequest request, C
         Type entityType = GetEntityTypeByName(primaryTypeName);
         var data = await CallGetAllPrimaryEntityDynamicAsync(entityType, primaryEntityName, filterStr, ct);
 
-        using var semaphore = new SemaphoreSlim(10); // Limit to 10 concurrent requests
+        using var semaphore = new SemaphoreSlim(concurrentRequests); // Limit to 10 concurrent requests
 
         var tasks = data.Select(async a =>
         {
@@ -192,8 +192,8 @@ private async Task<IEnumerable<T>> GetAllPrimaryEntityAsync<T>(string primaryEnt
         var property = _context.GetType().GetProperty(primaryEntityName);
         if (property == null) throw new Exception("Property not found.");
 
-        dynamic query = property.GetValue(_context) as DataServiceQuery;
-        query.AddQueryOption("$filter", filterStr)
+        var query = property.GetValue(_context) as DataServiceQuery<T>;
+        query = query.AddQueryOption("$filter", filterStr)
             .IncludeCount();
 
         var allEntities = new List<T>();