anchor.diff:                          | Some n -> local { return n }
                           | _ -> Cloud.GetWorkerCount()
                       let! workers = Cloud.GetAvailableWorkers()
  +                    let workers = workers |> Array.sortBy (fun workerRef -> workerRef.Id)
   
                       let rangeBasedReadLines (s : int64) (e : int64) (flow : System.IO.Stream) = 
                           seq {
  
positive.code:                             | None -> return! Cloud.GetWorkerCount()
                          }
                          let! workers = Cloud.GetAvailableWorkers()
  
                          // TODO : need a scheduling algorithm to assign partition indices
                          //        to workers according to current cache state.
  
negative.code:                             | Some n -> local { return n }
                              | _ -> Cloud.GetWorkerCount()
                          let! workers = Cloud.GetAvailableWorkers() 
                          let workers = workers |> Array.sortBy (fun workerRef -> workerRef.Id)
  
                          let createTask (files : CloudFile []) (collectorf : Local<Collector<'T, 'S>>) : Local<'R> = 
                              local {
  