Skip to content

Commit

Permalink
run pipeline time log
Browse files Browse the repository at this point in the history
  • Loading branch information
pavan02 committed May 4, 2022
1 parent a45a3b2 commit bcc3fda
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions src/queryExecution/source/PipelineStage.cc
Original file line number Diff line number Diff line change
Expand Up @@ -907,9 +907,14 @@ void PipelineStage::executePipelineWork(int i,
<< "-" << this->jobStage->getTargetComputationSpecifier()
<< std::chrono::duration_cast<std::chrono::duration<float>>(end - begin).count()
<< " secs." << std::endl;
auto start = std::chrono::high_resolution_clock::now();
std::cout << i<<": Running Pipeline\n";
curPipeline->id = i;
curPipeline->run();
end = std::chrono::high_resolution_clock::now();
std::cout << "RunPipeline Duration : "
<< std::chrono::duration_cast<std::chrono::duration<float>>(end - begin).count()
<< " secs." << std::endl;
curPipeline = nullptr;
newPlan->nullifyPlanPointer();
getAllocator().setPolicy(AllocatorPolicy::defaultAllocator);
Expand Down

0 comments on commit bcc3fda

Please sign in to comment.