Commit 63046b49 authored by Alessio Netti's avatar Alessio Netti
Browse files

Analytics: minor fix to timestamp assignment in Job Aggregator

parent b3b06296
......@@ -38,6 +38,10 @@ JobAggregatorOperator::~JobAggregatorOperator() {}
void JobAggregatorOperator::compute(U_Ptr unit, qeJobData& jobData) {
uint64_t now = getTimestamp() - _goBack;
// Too early to fetch job data
if(now < jobData.startTime) {
return;
}
// Making sure that the aggregation boundaries do not go past the job start/end time
uint64_t jobEnd = jobData.endTime!=0 && now > jobData.endTime ? jobData.endTime : now;
uint64_t jobStart = jobEnd-_window < jobData.startTime ? jobData.startTime : jobEnd-_window;
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment