varnitgoyal95/litmus-be
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

TP-12345 | fix start time of query (#73)

Browse Source
This commit is contained in:
Akshat Soni
2023-05-08 20:32:24 +05:30
committed by GitHub Enterprise
parent fe5251dad7
commit 29b53abb11
4 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
litmus-core/src/main/java/com/navi/medici/service/experimentmetricresult/ExperimentMetricResultServiceImpl.java
View File

@@ -198,7 +198,7 @@ public class ExperimentMetricResultServiceImpl implements ExperimentMetricResult
LocalDateTime scheduleTime = LocalDateTime.now();
variableMap.put(Constants.SCHEDULE_TIME, DateTimeUtil.convertToSpacedISODateTime(scheduleTime));
variableMap.put(Constants.END_TIME, DateTimeUtil.convertToSpacedISODateTime(scheduleTime.minusHours(litmusCoreConfig.getQueryScheduleAndEndTimeDiff())));
List<ExperimentMetricResultEntity> experimentResults = experimentMetricResultQuery.findByExperiment(experiment);
List<ExperimentMetricResultEntity> experimentResults = experimentMetricResultQuery.findByExperimentAndMetricOrderByTimestampAsc(experiment, metric);
if (experimentResults.isEmpty()) {
variableMap.put(Constants.START_TIME, DateTimeUtil.convertToSpacedISODateTime(scheduleTime.minusDays(1)));
} else {

6
litmus-db/src/main/java/com/navi/medici/query/experimentmetricresult/ExperimentMetricResultQueryImpl.java
View File

@@ -37,6 +37,12 @@ public class ExperimentMetricResultQueryImpl implements IExperimentMetricResultQ
return experimentMetricResultRepository.findByExperiment(experiment);
}
@Override
public List<ExperimentMetricResultEntity> findByExperimentAndMetricOrderByTimestampAsc(ExperimentEntity experiment, MetricEntity metric) {
return experimentMetricResultRepository.findByExperimentAndMetricOrderByTimestampAsc(experiment, metric);
}
@Override
public List<ExperimentMetricResultEntity> findByExperimentUpdatedAfter(ExperimentEntity experiment, LocalDateTime updatedAfter) {
return experimentMetricResultRepository.findByExperimentAndUpdatedAtAfter(experiment, updatedAfter);

2
litmus-db/src/main/java/com/navi/medici/query/experimentmetricresult/IExperimentMetricResultQuery.java
View File

@@ -17,5 +17,7 @@ public interface IExperimentMetricResultQuery {
List<ExperimentMetricResultEntity> findByExperiment(ExperimentEntity experiment);
List<ExperimentMetricResultEntity> findByExperimentAndMetricOrderByTimestampAsc(ExperimentEntity experiment, MetricEntity metric);
List<ExperimentMetricResultEntity> findByExperimentUpdatedAfter(ExperimentEntity experiment, LocalDateTime updatedAfter);
}

2
litmus-db/src/main/java/com/navi/medici/repository/ExperimentMetricResultRepository.java
View File

@@ -18,5 +18,7 @@ public interface ExperimentMetricResultRepository extends CrudRepository<Experim
List<ExperimentMetricResultEntity> findByExperiment(ExperimentEntity experiment);
List<ExperimentMetricResultEntity> findByExperimentAndMetricOrderByTimestampAsc(ExperimentEntity experiment, MetricEntity metric);
List<ExperimentMetricResultEntity> findByExperimentAndUpdatedAtAfter(ExperimentEntity experiment, LocalDateTime updatedAfter);
}