diff --git a/dbs/bulkblocks.go b/dbs/bulkblocks.go index 4148c4dc..930df060 100644 --- a/dbs/bulkblocks.go +++ b/dbs/bulkblocks.go @@ -438,6 +438,7 @@ func (a *API) InsertBulkBlocks() error { PROCESSING_ERA_ID: processingEraID, PHYSICS_GROUP_ID: physicsGroupID, XTCROSSSECTION: rec.Dataset.Xtcrosssection, + PREP_ID: rec.Dataset.PrepID, CREATION_DATE: rec.Dataset.CreationDate, CREATE_BY: rec.Dataset.CreateBy, LAST_MODIFICATION_DATE: creationDate, diff --git a/dbs/bulkblocks2.go b/dbs/bulkblocks2.go index 40721792..28726975 100644 --- a/dbs/bulkblocks2.go +++ b/dbs/bulkblocks2.go @@ -384,6 +384,7 @@ func getDatasetID( processingEraID int64, physicsGroupID int64, xtcrosssection float64, + prepId string, creationDate int64, createBy string, lastModificationDate int64, @@ -410,6 +411,7 @@ func getDatasetID( PROCESSING_ERA_ID: processingEraID, PHYSICS_GROUP_ID: physicsGroupID, XTCROSSSECTION: xtcrosssection, + PREP_ID: prepId, CREATION_DATE: creationDate, CREATE_BY: createBy, LAST_MODIFICATION_DATE: lastModificationDate, @@ -578,6 +580,7 @@ func (a *API) InsertBulkBlocksConcurrently() error { processingEraID, physicsGroupID, rec.Dataset.Xtcrosssection, + rec.Dataset.PrepID, rec.Dataset.CreationDate, rec.Dataset.CreateBy, creationDate,