create_batchcentroid.whizzml

(define (make-dataset src-id)
  (create-and-wait "dataset" {"source" src-id}))

(define (make-cluster ds-id)
  (create-and-wait "cluster" {"dataset" ds-id}))

(define (make-batchcentroid c-id ds-id)
  (let (bc-id (create-and-wait "batchcentroid" {"cluster" c-id
                                                "dataset" ds-id 
                                                "output_dataset" true 
                                                "all_fields" true}))
    (get (fetch bc-id) "output_dataset_resource")))

(define (source->batch-centroid src-id)
  (let (ds-id (make-dataset src-id)
        cl-id (make-cluster ds-id))
    (make-batchcentroid cl-id ds-id)))

(define dataset-id (source->batch-centroid source_id))