Skip to content

Commit 8d02061

Browse files
committed
Fixed NRE in cleanup orphaned data job #779
1 parent 8e76131 commit 8d02061

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/Exceptionless.Core/Jobs/CleanupOrphanedDataJob.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ public async Task DeleteOrphanedEventsByProjectAsync(JobContext context) {
103103
var projectCardinality = await _elasticClient.SearchAsync<PersistentEvent>(s => s.Aggregations(a => a
104104
.Cardinality("cardinality_project_id", c => c.Field(f => f.ProjectId).PrecisionThreshold(40000))));
105105

106-
var uniqueProjectIdCount = projectCardinality.Aggregations.Cardinality("cardinality_project_id").Value;
106+
var uniqueProjectIdCount = projectCardinality.Aggregations.Cardinality("cardinality_project_id")?.Value;
107107
if (!uniqueProjectIdCount.HasValue || uniqueProjectIdCount.Value <= 0)
108108
return;
109109

@@ -146,7 +146,7 @@ public async Task DeleteOrphanedEventsByOrganizationAsync(JobContext context) {
146146
var organizationCardinality = await _elasticClient.SearchAsync<PersistentEvent>(s => s.Aggregations(a => a
147147
.Cardinality("cardinality_organization_id", c => c.Field(f => f.OrganizationId).PrecisionThreshold(40000))));
148148

149-
var uniqueOrganizationIdCount = organizationCardinality.Aggregations.Cardinality("cardinality_organization_id").Value;
149+
var uniqueOrganizationIdCount = organizationCardinality.Aggregations.Cardinality("cardinality_organization_id")?.Value;
150150
if (!uniqueOrganizationIdCount.HasValue || uniqueOrganizationIdCount.Value <= 0)
151151
return;
152152

0 commit comments

Comments
 (0)