Skip to content

Commit 1226774

Browse files
authored
Merge pull request #460 from rest-for-physics/jgalan-dataset
Increasing default verbose level of `restManager` to `Info`
2 parents ee6baf3 + 867a885 commit 1226774

File tree

2 files changed

+17
-1
lines changed

2 files changed

+17
-1
lines changed

source/bin/restManager.cxx

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -158,6 +158,7 @@ int main(int argc, char* argv[]) {
158158
// Load libraries
159159
TRestTools::LoadRESTLibrary(true);
160160
gInterpreter->ProcessLine("#define REST_MANAGER");
161+
gVerbose = StringToVerboseLevel("2");
161162

162163
// read arguments
163164
if (args.size() >= 2) {

source/framework/core/src/TRestDataSet.cxx

Lines changed: 16 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -345,20 +345,25 @@ void TRestDataSet::GenerateDataSet() {
345345

346346
ROOT::EnableImplicitMT();
347347

348+
RESTInfo << "Initializing dataset" << RESTendl;
348349
fDataSet = ROOT::RDataFrame("AnalysisTree", fFileSelection);
349350

351+
RESTInfo << "Making cuts" << RESTendl;
350352
fDataSet = MakeCut(fCut);
351353

352354
// Adding new user columns added to the dataset
353355
for (const auto& [cName, cExpression] : fColumnNameExpressions) {
356+
RESTInfo << "Adding column to dataset: " << cName << RESTendl;
354357
finalList.emplace_back(cName);
355358
fDataSet = DefineColumn(cName, cExpression);
356359
}
357360

361+
RESTInfo << "Generating snapshot." << RESTendl;
358362
std::string user = getenv("USER");
359363
std::string fOutName = "/tmp/rest_output_" + user + ".root";
360364
fDataSet.Snapshot("AnalysisTree", fOutName, finalList);
361365

366+
RESTInfo << "Re-importing analysis tree." << RESTendl;
362367
fDataSet = ROOT::RDataFrame("AnalysisTree", fOutName);
363368

364369
TFile* f = TFile::Open(fOutName.c_str());
@@ -392,8 +397,17 @@ std::vector<std::string> TRestDataSet::FileSelection() {
392397
}
393398

394399
fTotalDuration = 0;
400+
std::cout << "Total files : " << fileNames.size() << std::endl;
401+
std::cout << "Processing file selection .";
402+
int cnt = 1;
395403
for (const auto& file : fileNames) {
404+
if (cnt % 100 == 0) {
405+
std::cout << std::endl;
406+
std::cout << "Files processed: " << cnt << " ." << std::flush;
407+
}
408+
cnt++;
396409
TRestRun run(file);
410+
std::cout << "." << std::flush;
397411
double runStart = run.GetStartTimestamp();
398412
double runEnd = run.GetEndTimestamp();
399413

@@ -464,7 +478,7 @@ std::vector<std::string> TRestDataSet::FileSelection() {
464478
fTotalDuration += run.GetEndTimestamp() - run.GetStartTimestamp();
465479
fFileSelection.push_back(file);
466480
}
467-
RESTInfo << RESTendl;
481+
std::cout << std::endl;
468482

469483
return fFileSelection;
470484
}
@@ -760,6 +774,7 @@ void TRestDataSet::InitFromConfigFile() {
760774
/// of the TRestDataSet instance that contains the conditions used to generate the dataset.
761775
///
762776
void TRestDataSet::Export(const std::string& filename) {
777+
RESTInfo << "Exporting dataset" << RESTendl;
763778
if (TRestTools::GetFileNameExtension(filename) == "txt" ||
764779
TRestTools::GetFileNameExtension(filename) == "csv") {
765780
std::vector<std::string> dataTypes;

0 commit comments

Comments
 (0)