diff --git a/src/FunderMaps.Core/HealthChecks/TippecanoeHealthCheck.cs b/src/FunderMaps.Core/HealthChecks/TippecanoeHealthCheck.cs index 0ac95dd6..352769ba 100644 --- a/src/FunderMaps.Core/HealthChecks/TippecanoeHealthCheck.cs +++ b/src/FunderMaps.Core/HealthChecks/TippecanoeHealthCheck.cs @@ -26,7 +26,7 @@ public async Task CheckHealthAsync(HealthCheckContext context { logger.LogTrace(exception, "Health check failed"); - return HealthCheckResult.Unhealthy("blob storage service"); + return HealthCheckResult.Unhealthy("tileset generator is unhealthy"); } } } diff --git a/src/FunderMaps.Data/Repositories/AddressRepository.cs b/src/FunderMaps.Data/Repositories/AddressRepository.cs index 9c21283e..0c8e93b1 100644 --- a/src/FunderMaps.Data/Repositories/AddressRepository.cs +++ b/src/FunderMaps.Data/Repositories/AddressRepository.cs @@ -107,7 +107,7 @@ OFFSET @offset await using var connection = DbContextFactory.DbProvider.ConnectionScope(); - foreach (var item in await connection.QueryAsync
(sql, navigation)) + await foreach (var item in connection.QueryUnbufferedAsync
(sql, navigation)) { yield return CacheEntity(item); } diff --git a/src/FunderMaps.Data/Repositories/AnalysisRepository.cs b/src/FunderMaps.Data/Repositories/AnalysisRepository.cs index eeb9cd3d..583e3c7e 100644 --- a/src/FunderMaps.Data/Repositories/AnalysisRepository.cs +++ b/src/FunderMaps.Data/Repositories/AnalysisRepository.cs @@ -222,7 +222,7 @@ public async IAsyncEnumerable ListAllAsync(Navigation navigatio await using var connection = DbContextFactory.DbProvider.ConnectionScope(); - foreach (var item in await connection.QueryAsync(sql, navigation)) + await foreach (var item in connection.QueryUnbufferedAsync(sql, navigation)) { yield return item; } diff --git a/src/FunderMaps.Data/Repositories/BuildingRepository.cs b/src/FunderMaps.Data/Repositories/BuildingRepository.cs index 387ee85b..b98f1322 100644 --- a/src/FunderMaps.Data/Repositories/BuildingRepository.cs +++ b/src/FunderMaps.Data/Repositories/BuildingRepository.cs @@ -117,7 +117,7 @@ OFFSET @offset await using var connection = DbContextFactory.DbProvider.ConnectionScope(); - foreach (var item in await connection.QueryAsync(sql, navigation)) + await foreach (var item in connection.QueryUnbufferedAsync(sql, navigation)) { yield return CacheEntity(item); } diff --git a/src/FunderMaps.Data/Repositories/BundleRepository.cs b/src/FunderMaps.Data/Repositories/BundleRepository.cs index d6cc77d0..a8542540 100644 --- a/src/FunderMaps.Data/Repositories/BundleRepository.cs +++ b/src/FunderMaps.Data/Repositories/BundleRepository.cs @@ -80,7 +80,7 @@ OFFSET @offset await using var connection = DbContextFactory.DbProvider.ConnectionScope(); - foreach (var item in await connection.QueryAsync(sql, navigation)) + await foreach (var item in connection.QueryUnbufferedAsync(sql, navigation)) { yield return CacheEntity(item); } @@ -108,7 +108,7 @@ WHERE enabled await using var connection = DbContextFactory.DbProvider.ConnectionScope(); - foreach (var item in await connection.QueryAsync(sql)) + await foreach (var item in connection.QueryUnbufferedAsync(sql)) { yield return CacheEntity(item); } diff --git a/src/FunderMaps.Data/Repositories/ContractorRepository.cs b/src/FunderMaps.Data/Repositories/ContractorRepository.cs index 5b7a3c31..5f43cca8 100644 --- a/src/FunderMaps.Data/Repositories/ContractorRepository.cs +++ b/src/FunderMaps.Data/Repositories/ContractorRepository.cs @@ -54,7 +54,7 @@ public override async IAsyncEnumerable ListAllAsync(Navigation navig await using var connection = DbContextFactory.DbProvider.ConnectionScope(); - foreach (var item in await connection.QueryAsync(sql)) + await foreach (var item in connection.QueryUnbufferedAsync(sql)) { yield return CacheEntity(item); } diff --git a/src/FunderMaps.Data/Repositories/KeystoreRepository.cs b/src/FunderMaps.Data/Repositories/KeystoreRepository.cs index 0ea9b5fb..3344f2a8 100644 --- a/src/FunderMaps.Data/Repositories/KeystoreRepository.cs +++ b/src/FunderMaps.Data/Repositories/KeystoreRepository.cs @@ -52,7 +52,7 @@ public override async IAsyncEnumerable ListAllAsync(Navigation navigat await using var connection = DbContextFactory.DbProvider.ConnectionScope(); - foreach (var item in await connection.QueryAsync(sql)) + await foreach (var item in connection.QueryUnbufferedAsync(sql)) { yield return item; } diff --git a/src/FunderMaps.Data/Repositories/MapsetRepository.cs b/src/FunderMaps.Data/Repositories/MapsetRepository.cs index eee6eee2..03477116 100644 --- a/src/FunderMaps.Data/Repositories/MapsetRepository.cs +++ b/src/FunderMaps.Data/Repositories/MapsetRepository.cs @@ -87,7 +87,7 @@ FROM maplayer.map_organization mo await using var connection = DbContextFactory.DbProvider.ConnectionScope(); - foreach (var item in await connection.QueryAsync(sql, new { id })) + await foreach (var item in connection.QueryUnbufferedAsync(sql, new { id })) { yield return item; } diff --git a/src/FunderMaps.Data/Repositories/NeighborhoorRepository.cs b/src/FunderMaps.Data/Repositories/NeighborhoorRepository.cs index ec7cc8db..509be59b 100644 --- a/src/FunderMaps.Data/Repositories/NeighborhoorRepository.cs +++ b/src/FunderMaps.Data/Repositories/NeighborhoorRepository.cs @@ -145,7 +145,7 @@ OFFSET @offset await using var connection = DbContextFactory.DbProvider.ConnectionScope(); - foreach (var item in await connection.QueryAsync(sql, navigation)) + await foreach (var item in connection.QueryUnbufferedAsync(sql, navigation)) { yield return CacheEntity(item); } diff --git a/src/FunderMaps.Data/Repositories/TelemetryRepository.cs b/src/FunderMaps.Data/Repositories/TelemetryRepository.cs index e098d344..1b8ebf65 100644 --- a/src/FunderMaps.Data/Repositories/TelemetryRepository.cs +++ b/src/FunderMaps.Data/Repositories/TelemetryRepository.cs @@ -80,7 +80,7 @@ FROM application.product_tracker AS pt await using var connection = DbContextFactory.DbProvider.ConnectionScope(); - foreach (var item in await connection.QueryAsync(sql)) + await foreach (var item in connection.QueryUnbufferedAsync(sql)) { yield return item; } @@ -104,7 +104,7 @@ FROM application.product_tracker AS pt await using var connection = DbContextFactory.DbProvider.ConnectionScope(); - foreach (var item in await connection.QueryAsync(sql, new { id })) + await foreach (var item in connection.QueryUnbufferedAsync(sql, new { id })) { yield return item; }