anchor.diff:                      if request.ForceCreate then queueService.AddDocumentQueue(document)
                       else queueService.AddOrUpdateDocumentQueue(document)
                       rows <- rows + 1
  -                    if rows % 5000 = 0 then 
  -                        jobService.UpdateJob(jobId, JobStatus.InProgress, rows)
  +                    if rows % 5000 = 0 then jobService.UpdateJob(jobId, JobStatus.InProgress, rows)
                   jobService.UpdateJob(jobId, JobStatus.Completed, rows)
  -                Logger.Log (sprintf "SQL connector: Job Finished. Query:{%s}. Index:{%s}" request.Query request.IndexName, MessageKeyword.Plugin, MessageLevel.Info)
  -            else
  -                jobService.UpdateJob(jobId, JobStatus.CompletedWithErrors, rows, "No rows returned.") 
  -                Logger.Log (sprintf "SQL connector error. No rows returned. Query:{%s}" request.Query, MessageKeyword.Plugin, MessageLevel.Error)
  +                Logger.Log
  +                    (sprintf "SQL connector: Job Finished. Query:{%s}. Index:{%s}" request.Query request.IndexName, 
  +                     MessageKeyword.Plugin, MessageLevel.Info)
  +            else 
  +                jobService.UpdateJob(jobId, JobStatus.CompletedWithErrors, rows, "No rows returned.")
  +                Logger.Log
  +                    (sprintf "SQL connector error. No rows returned. Query:{%s}" request.Query, MessageKeyword.Plugin, 
  +                     MessageLevel.Error)
           with e -> 
  -                jobService.UpdateJob(jobId, JobStatus.CompletedWithErrors, 0, (e |> exceptionPrinter))
  -                Logger.Log (sprintf "SQL connector error: %s" (e |> exceptionPrinter), MessageKeyword.Plugin, MessageLevel.Error)
  +            jobService.UpdateJob(jobId, JobStatus.CompletedWithErrors, 0, (e |> exceptionPrinter))
  +            Logger.Log
  +                (sprintf "SQL connector error: %s" (e |> exceptionPrinter), MessageKeyword.Plugin, MessageLevel.Error)
       
       let bulkRequestProcessor = 
           MailboxProcessor.Start(fun inbox -> 
  
positive.code: /// Connector for importing CSV file data into the system.
  [<Sealed>]
  [<Name("POST-/indices/:id/csv")>]
  type CsvHandler(queueService : IQueueService, jobService : IJobService) = 
      inherit HttpHandlerBase<CsvIndexingRequest, string>()
      
      //    let ProcessFileUsingCsvHelper(body : CsvIndexingRequest, path : string) = 
  
negative.code:             else body.Headers
          match headers with
          | [||] -> 
              (!>) "CSV Parsing failed. No header row. File: %s" path
              fail <| HeaderRowIsEmpty
          | _ -> 
              let mutable rows = 0L
  