Switched batch size to 50. Added logging of batch size.

diff --git a/services/datamanager/collection/collection.go b/services/datamanager/collection/collection.go
index 212e33f7b370c6bd12593f445b74c0232c0ec506..7e94a116181fed701a84020e37cbe15e1942b174 100644 (file)
--- a/services/datamanager/collection/collection.go
+++ b/services/datamanager/collection/collection.go
@@ -127,6 +127,7 @@ func GetCollections(params GetCollectionsParams) (results ReadCollections) {
                properties,_ := params.Logger.Edit()
                collectionInfo := make(map[string]interface{})
                collectionInfo["num_collections_at_start"] = initialNumberOfCollectionsAvailable
+               collectionInfo["batch_size"] = params.BatchSize
                properties["collection_info"] = collectionInfo
                params.Logger.Record()
        }

diff --git a/services/datamanager/datamanager.go b/services/datamanager/datamanager.go
index bf989026c45189db29a7a1ca10c8c785c7a383ac..92dd9c5ff46268ded190d123b2c4230be6954382 100644 (file)
--- a/services/datamanager/datamanager.go
+++ b/services/datamanager/datamanager.go
@@ -75,7 +75,7 @@ func main() {
        // This requires waiting on them to finish before you let main() exit.
 
        RunCollections(collection.GetCollectionsParams{
-               Client: arv, Logger: arvLogger, BatchSize: 100})
+               Client: arv, Logger: arvLogger, BatchSize: 50})
 
        RunKeep(keep.GetKeepServersParams{Client: arv, Limit: 1000})
 }