anchor.diff:                      if request.ForceCreate then queueService.AddDocumentQueue(document)
                       else queueService.AddOrUpdateDocumentQueue(document)
                       rows <- rows + 1
  -                    if jobId |> isNotBlank && rows % 5000 = 0 then 
  +                    if jobId
  +                       |> isNotBlank
  +                       && rows % 5000 = 0 then 
                           let job = 
                               new Job(JobId = jobId, Status = JobStatus.InProgress, Message = "", ProcessedItems = rows)
                           jobService.UpdateJob(job) |> ignore
  -
                   if jobId |> isNotBlank then 
                       let job = 
                           new Job(JobId = jobId, Status = JobStatus.Completed, Message = "Completed", 
  
positive.code:             loop())
      
      let processRequest index (body : SqlIndexingRequest) = 
          let createJob () = 
              if body.CreateJob then 
                  let guid = Guid.NewGuid()
                  bulkRequestProcessor.Post(body, guid.ToString())
  
negative.code:                     let! (body : CsvIndexingRequest, path : string, jobId : Guid, isFolder : bool) = inbox.Receive()
                      let job = new Job(JobId = jobId.ToString("N"), Status = JobStatus.InProgress)
                      jobService.UpdateJob(job) |> ignore
                      let execFileJob filePath = 
                          match ProcessFile(body, filePath) with
                          | Choice1Of2() -> 
  