Skip to content
Permalink

Comparing changes

This is a direct comparison between two commits made in this repository or its related repositories. View the default comparison for this range or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: fidlabs/compliance-data-platform
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: eb3e3e78d62a473fe3bc795a7f833976daef2d7d
Choose a base ref
..
head repository: fidlabs/compliance-data-platform
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: 2a3cb955254b1d54e68439d39b55cf0c0ca6e04c
Choose a head ref
Showing with 6 additions and 2 deletions.
  1. +2 −2 src/aggregation/runners/client-claims.runner.ts
  2. +4 −0 src/aggregation/runners/client-provider-distribution-acc.runner.ts
4 changes: 2 additions & 2 deletions src/aggregation/runners/client-claims.runner.ts
View file
Original file line number Diff line number Diff line change
@@ -55,7 +55,7 @@ export class ClientClaimsRunner implements AggregationRunner {
if (isFirstInsert) {
isFirstInsert = false;
getDataEndTimerMetric();
const storeDataEndTimerMetric =
storeDataEndTimerMetric =
startStoreDataTimerByRunnerNameMetric(runnerName);
await tx.$executeRaw`delete from client_claims_hourly`;
}
@@ -71,7 +71,7 @@ export class ClientClaimsRunner implements AggregationRunner {
if (data.length > 0) {
if (isFirstInsert) {
getDataEndTimerMetric();
const storeDataEndTimerMetric =
storeDataEndTimerMetric =
startStoreDataTimerByRunnerNameMetric(runnerName);
await tx.$executeRaw`delete from client_claims_hourly`;
}
4 changes: 4 additions & 0 deletions src/aggregation/runners/client-provider-distribution-acc.runner.ts
View file
Original file line number Diff line number Diff line change
@@ -18,6 +18,10 @@ export class ClientProviderDistributionAccRunner implements AggregationRunner {
prometheusMetricService,
}: AggregationRunnerRunServices): Promise<void> {
const runnerName = this.getName();
const {
startGetDataTimerByRunnerNameMetric,
startStoreDataTimerByRunnerNameMetric,
} = prometheusMetricService.aggregateMetrics;

//const latestStored =
// await prismaService.client_provider_distribution_weekly_acc.findFirst({