diff --git a/java/cdk/src/main/java/sleeper/cdk/stack/TransactionLogSnapshotCreationStack.java b/java/cdk/src/main/java/sleeper/cdk/stack/TransactionLogSnapshotCreationStack.java index 823ca94435..61a4369b11 100644 --- a/java/cdk/src/main/java/sleeper/cdk/stack/TransactionLogSnapshotCreationStack.java +++ b/java/cdk/src/main/java/sleeper/cdk/stack/TransactionLogSnapshotCreationStack.java @@ -54,7 +54,7 @@ import static sleeper.configuration.properties.instance.CommonProperty.TABLE_BATCHING_LAMBDAS_MEMORY_IN_MB; import static sleeper.configuration.properties.instance.CommonProperty.TABLE_BATCHING_LAMBDAS_TIMEOUT_IN_SECONDS; import static sleeper.configuration.properties.instance.CommonProperty.TRANSACTION_LOG_SNAPSHOT_CREATION_BATCH_SIZE; -import static sleeper.configuration.properties.instance.CommonProperty.TRANSACTION_LOG_SNAPSHOT_CREATION_LAMBDA_PERIOD_IN_MINUTES;; +import static sleeper.configuration.properties.instance.CommonProperty.TRANSACTION_LOG_SNAPSHOT_CREATION_LAMBDA_PERIOD_IN_SECONDS;; public class TransactionLogSnapshotCreationStack extends NestedStack { @@ -92,7 +92,7 @@ public TransactionLogSnapshotCreationStack( Rule rule = Rule.Builder.create(this, "TransactionLogSnapshotCreationSchedule") .ruleName(SleeperScheduleRule.TRANSACTION_LOG_SNAPSHOT_CREATION.buildRuleName(instanceProperties)) .schedule(Schedule.rate(Duration.minutes( - instanceProperties.getLong(TRANSACTION_LOG_SNAPSHOT_CREATION_LAMBDA_PERIOD_IN_MINUTES)))) + instanceProperties.getLong(TRANSACTION_LOG_SNAPSHOT_CREATION_LAMBDA_PERIOD_IN_SECONDS)))) .targets(List.of(new LambdaFunction(snapshotCreationTrigger))) .enabled(!shouldDeployPaused(this)) .build(); diff --git a/java/configuration/src/main/java/sleeper/configuration/properties/instance/CdkDefinedInstanceProperty.java b/java/configuration/src/main/java/sleeper/configuration/properties/instance/CdkDefinedInstanceProperty.java index ff6ead819b..e23eccd162 100644 --- a/java/configuration/src/main/java/sleeper/configuration/properties/instance/CdkDefinedInstanceProperty.java +++ b/java/configuration/src/main/java/sleeper/configuration/properties/instance/CdkDefinedInstanceProperty.java @@ -103,19 +103,19 @@ public interface CdkDefinedInstanceProperty extends InstanceProperty { .propertyGroup(InstancePropertyGroup.COMMON) .build(); CdkDefinedInstanceProperty TRANSACTION_LOG_SNAPSHOT_CREATION_QUEUE_URL = Index.propertyBuilder("sleeper.metadata.transactionlog.snapshots.creation.queue.url") - .description("URL of the queue for sending batches of transaction log snapshot creation requests.") + .description("URL of the queue for transaction log snapshot creation requests.") .propertyGroup(InstancePropertyGroup.COMMON) .build(); CdkDefinedInstanceProperty TRANSACTION_LOG_SNAPSHOT_CREATION_QUEUE_ARN = Index.propertyBuilder("sleeper.metadata.transactionlog.snapshots.creation.queue.arn") - .description("The ARN of the queue for sending batches of transaction log snapshot creation requests.") + .description("The ARN of the queue for transaction log snapshot creation requests.") .propertyGroup(InstancePropertyGroup.COMMON) .build(); CdkDefinedInstanceProperty TRANSACTION_LOG_SNAPSHOT_CREATION_DLQ_URL = Index.propertyBuilder("sleeper.metadata.transactionlog.snapshots.creation.dlq.url") - .description("The URL of the dead letter queue for sending batches of transaction log snapshot creation requests.") + .description("The URL of the dead letter queue for transaction log snapshot creation requests.") .propertyGroup(InstancePropertyGroup.COMMON) .build(); CdkDefinedInstanceProperty TRANSACTION_LOG_SNAPSHOT_CREATION_DLQ_ARN = Index.propertyBuilder("sleeper.metadata.transactionlog.snapshots.creation.dlq.arn") - .description("The ARN of the dead letter queue for sending batches of transaction log snapshot creation requests.") + .description("The ARN of the dead letter queue for transaction log snapshot creation requests.") .propertyGroup(InstancePropertyGroup.COMMON) .build(); CdkDefinedInstanceProperty TRANSACTION_LOG_SNAPSHOT_CREATION_RULE = Index.propertyBuilder("sleeper.metadata.transactionlog.snapshots.creation.rule") diff --git a/java/configuration/src/main/java/sleeper/configuration/properties/instance/CommonProperty.java b/java/configuration/src/main/java/sleeper/configuration/properties/instance/CommonProperty.java index 6693f60bd1..320f824b76 100644 --- a/java/configuration/src/main/java/sleeper/configuration/properties/instance/CommonProperty.java +++ b/java/configuration/src/main/java/sleeper/configuration/properties/instance/CommonProperty.java @@ -201,7 +201,7 @@ public interface CommonProperty { .validationPredicate(Utils::isPositiveIntegerLtEq10) .propertyGroup(InstancePropertyGroup.COMMON) .build(); - UserDefinedInstanceProperty TRANSACTION_LOG_SNAPSHOT_CREATION_LAMBDA_PERIOD_IN_MINUTES = Index.propertyBuilder("sleeper.metadata.transactionlog.snapshot.creation.lambda.period.minutes") + UserDefinedInstanceProperty TRANSACTION_LOG_SNAPSHOT_CREATION_LAMBDA_PERIOD_IN_SECONDS = Index.propertyBuilder("sleeper.metadata.transactionlog.snapshot.creation.lambda.period.seconds") .description("The frequency in minutes with which the transaction log snapshot creation lambda is run.") .defaultValue("5") .validationPredicate(Utils::isPositiveInteger)