- Increase initial import write chunk sizes
- Browse files
-
bogdan committed 5 days ago
Showing 2 changed files
with
6 additions
and
6 deletions
+3
-3
HealthProbe/Services/HealthKitService.swift
@@ -2751,7 +2751,7 @@ enum DistributionCaptureConfiguration {
|
||
| 2751 | 2751 |
if veryHighVolumeTypeIdentifiers.contains(typeIdentifier) {
|
| 2752 | 2752 |
return DistributionCaptureStrategy( |
| 2753 | 2753 |
queryPageLimit: 2_000, |
| 2754 |
- initialWriteChunkSize: 2_000, |
|
| 2754 |
+ initialWriteChunkSize: 5_000, |
|
| 2755 | 2755 |
initialArchiveFlushSampleLimit: 10_000, |
| 2756 | 2756 |
minimumWriteChunkSize: 500, |
| 2757 | 2757 |
slowBatchThresholdSeconds: 2.5, |
@@ -2762,9 +2762,9 @@ enum DistributionCaptureConfiguration {
|
||
| 2762 | 2762 |
if highVolumeTypeIdentifiers.contains(typeIdentifier) {
|
| 2763 | 2763 |
return DistributionCaptureStrategy( |
| 2764 | 2764 |
queryPageLimit: 5_000, |
| 2765 |
- initialWriteChunkSize: 1_000, |
|
| 2765 |
+ initialWriteChunkSize: 2_500, |
|
| 2766 | 2766 |
initialArchiveFlushSampleLimit: 10_000, |
| 2767 |
- minimumWriteChunkSize: 250, |
|
| 2767 |
+ minimumWriteChunkSize: 500, |
|
| 2768 | 2768 |
slowBatchThresholdSeconds: 1.75, |
| 2769 | 2769 |
severeBatchThresholdSeconds: 4.5 |
| 2770 | 2770 |
) |
+3
-3
HealthProbeTests/DistributionCaptureConfigurationTests.swift
@@ -9,7 +9,7 @@ final class DistributionCaptureConfigurationTests: XCTestCase {
|
||
| 9 | 9 |
) |
| 10 | 10 |
|
| 11 | 11 |
XCTAssertEqual(strategy.queryPageLimit, 2_000) |
| 12 |
- XCTAssertEqual(strategy.initialWriteChunkSize, 2_000) |
|
| 12 |
+ XCTAssertEqual(strategy.initialWriteChunkSize, 5_000) |
|
| 13 | 13 |
XCTAssertEqual(strategy.initialArchiveFlushSampleLimit, 10_000) |
| 14 | 14 |
XCTAssertEqual(strategy.minimumWriteChunkSize, 500) |
| 15 | 15 |
XCTAssertEqual(strategy.slowBatchThresholdSeconds, 2.5) |
@@ -24,10 +24,10 @@ final class DistributionCaptureConfigurationTests: XCTestCase {
|
||
| 24 | 24 |
|
| 25 | 25 |
state.registerBatchDuration(strategy.severeBatchThresholdSeconds) |
| 26 | 26 |
|
| 27 |
- XCTAssertEqual(state.currentWriteChunkSize, 1_000) |
|
| 27 |
+ XCTAssertEqual(state.currentWriteChunkSize, 2_500) |
|
| 28 | 28 |
|
| 29 | 29 |
state.registerBatchDuration(strategy.severeBatchThresholdSeconds) |
| 30 | 30 |
|
| 31 |
- XCTAssertEqual(state.currentWriteChunkSize, 500) |
|
| 31 |
+ XCTAssertEqual(state.currentWriteChunkSize, 1_250) |
|
| 32 | 32 |
} |
| 33 | 33 |
} |