anchor.diff:      
       let ExecuteSql(request : SqlIndexingRequest, jobId) = 
           let isNotBlank = isBlank >> not
  -
           if request.CreateJob then 
               let job = new Job(JobId = jobId, Status = JobStatus.InProgress)
               jobService.UpdateJob(job) |> ignore
  -
           try 
               use connection = new SqlConnection(request.ConnectionString)
               use command = new SqlCommand(request.Query, Connection = connection, CommandType = CommandType.Text)
               command.CommandTimeout <- 300
               connection.Open()
               let mutable rows = 0
  -            
               use reader = command.ExecuteReader()
  -
               if reader.HasRows then 
                   while reader.Read() do
                       let document = new Document.Dto(IndexName = request.IndexName, Id = reader.[0].ToString())
  
positive.code:                 ""
              |> Choice1Of2
          body.IndexName <- index
  
          body.Validate()
          >>= createJob
      
      override this.Process(request, body) = 
          SomeResponse(processRequest request.ResName body.Value, Ok, BadRequest)
negative.code:             loop())
      
      let processRequest index (body : SqlIndexingRequest) = 
          let createJob() = 
              if body.CreateJob then 
                  let guid = Guid.NewGuid()
                  bulkRequestProcessor.Post(body, guid.ToString())
  