diff --git a/src/main/kotlin/dev/restate/sdktesting/infra/RestateContainer.kt b/src/main/kotlin/dev/restate/sdktesting/infra/RestateContainer.kt index b0c5615..94cd5e8 100644 --- a/src/main/kotlin/dev/restate/sdktesting/infra/RestateContainer.kt +++ b/src/main/kotlin/dev/restate/sdktesting/infra/RestateContainer.kt @@ -63,7 +63,7 @@ class RestateContainer( .build())) .withStartupTimeout(120.seconds.toJavaDuration()) - fun bootstrapRestateCluster( + fun createRestateContainers( config: RestateDeployerConfig, network: Network, envs: Map, @@ -79,14 +79,17 @@ class RestateContainer( val leaderEnvs = mapOf( "RESTATE_CLUSTER_NAME" to clusterId, - "RESTATE_BIFROST__DEFAULT_PROVIDER" to "replicated", "RESTATE_ALLOW_BOOTSTRAP" to "true", + "RESTATE_BIFROST__DEFAULT_PROVIDER" to "replicated", + "RESTATE_BIFROST__REPLICATED_LOGLET__DEFAULT_REPLICATION_PROPERTY" to "2", "RESTATE_ROLES" to "[worker,log-server,admin,metadata-store]", ) val followerEnvs = mapOf( "RESTATE_CLUSTER_NAME" to clusterId, + "RESTATE_ALLOW_BOOTSTRAP" to "false", "RESTATE_BIFROST__DEFAULT_PROVIDER" to "replicated", + "RESTATE_BIFROST__REPLICATED_LOGLET__DEFAULT_REPLICATION_PROPERTY" to "2", "RESTATE_ROLES" to "[worker,admin,log-server]", "RESTATE_METADATA_STORE_CLIENT__ADDRESS" to "http://$RESTATE_RUNTIME:$RUNTIME_NODE_PORT") diff --git a/src/main/kotlin/dev/restate/sdktesting/infra/RestateDeployer.kt b/src/main/kotlin/dev/restate/sdktesting/infra/RestateDeployer.kt index df26882..4832401 100644 --- a/src/main/kotlin/dev/restate/sdktesting/infra/RestateDeployer.kt +++ b/src/main/kotlin/dev/restate/sdktesting/infra/RestateDeployer.kt @@ -169,7 +169,7 @@ private constructor( } .associate { it.second.first to (it.first to it.second.second) } private val runtimeContainers: List = - RestateContainer.bootstrapRestateCluster( + RestateContainer.createRestateContainers( config, network, runtimeContainerEnvs, configSchema, copyToContainer, config.restateNodes) private val deployedContainers: Map =