This is an automated email from the ASF dual-hosted git repository.
ricardozanini pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-kie-tools.git
The following commit(s) were added to refs/heads/main by this push:
new 7eb52c9b9f3 incubator-kie-tools-3213: [sonataflow-operator] Adjust DI
and JS datasources configurations (#3214)
7eb52c9b9f3 is described below
commit 7eb52c9b9f3f41647e599fc4855f909f4070155b
Author: Walter Medvedeo <[email protected]>
AuthorDate: Fri Jul 25 20:55:41 2025 +0200
incubator-kie-tools-3213: [sonataflow-operator] Adjust DI and JS
datasources configurations (#3214)
---
.../controller/platform/db_migrator_job.go | 41 +++++++---------------
.../controller/platform/db_migrator_job_test.go | 2 +-
.../platform/services/properties_services_test.go | 2 --
.../controller/platform/services/services.go | 14 ++------
.../controller/profiles/common/object_creators.go | 2 +-
.../profiles/common/object_creators_test.go | 20 -----------
.../profiles/common/persistence/postgresql.go | 28 ++++++++-------
.../sonataflowplatform_controller_test.go | 7 +---
8 files changed, 33 insertions(+), 83 deletions(-)
diff --git
a/packages/sonataflow-operator/internal/controller/platform/db_migrator_job.go
b/packages/sonataflow-operator/internal/controller/platform/db_migrator_job.go
index cafa4af6c89..5b26c1df59c 100644
---
a/packages/sonataflow-operator/internal/controller/platform/db_migrator_job.go
+++
b/packages/sonataflow-operator/internal/controller/platform/db_migrator_job.go
@@ -24,7 +24,6 @@ import (
"errors"
"fmt"
"strconv"
- "strings"
"github.com/apache/incubator-kie-tools/packages/sonataflow-operator/api/version"
@@ -52,10 +51,6 @@ type QuarkusDataSource struct {
Schema string
}
-func (q *QuarkusDataSource) JdbcReactiveUrl() string {
- return strings.TrimPrefix(q.JdbcUrl, "jdbc:")
-}
-
type DBMigratorJob struct {
MigrateDBDataIndex bool
DataIndexDataSource *QuarkusDataSource
@@ -74,19 +69,17 @@ const (
dbMigrationJobFailed = 1
dbMigrationJobSucceeded = 1
- migrateDBDataIndex = "MIGRATE_DB_DATAINDEX"
- quarkusDataSourceDataIndexJdbcURL =
"QUARKUS_DATASOURCE_DATAINDEX_JDBC_URL"
- quarkusDataSourceDataIndexJdbcReactiveURL =
"QUARKUS_DATASOURCE_DATAINDEX_REACTIVE_URL"
- quarkusDataSourceDataIndexUserName =
"QUARKUS_DATASOURCE_DATAINDEX_USERNAME"
- quarkusDataSourceDataIndexPassword =
"QUARKUS_DATASOURCE_DATAINDEX_PASSWORD"
- quarkusFlywayDataIndexSchemas =
"QUARKUS_FLYWAY_DATAINDEX_SCHEMAS"
-
- migrateDBJobsService = "MIGRATE_DB_JOBSSERVICE"
- quarkusDataSourceJobsServiceJdbcURL =
"QUARKUS_DATASOURCE_JOBSSERVICE_JDBC_URL"
- quarkusDataSourceJobsServiceJdbcReactiveURL =
"QUARKUS_DATASOURCE_JOBSSERVICE_REACTIVE_URL"
- quarkusDataSourceJobsServiceUserName =
"QUARKUS_DATASOURCE_JOBSSERVICE_USERNAME"
- quarkusDataSourceJobsServicePassword =
"QUARKUS_DATASOURCE_JOBSSERVICE_PASSWORD"
- quarkusFlywayJobsServiceSchemas =
"QUARKUS_FLYWAY_JOBSSERVICE_SCHEMAS"
+ migrateDBDataIndex = "MIGRATE_DB_DATAINDEX"
+ quarkusDataSourceDataIndexJdbcURL =
"QUARKUS_DATASOURCE_DATAINDEX_JDBC_URL"
+ quarkusDataSourceDataIndexUserName =
"QUARKUS_DATASOURCE_DATAINDEX_USERNAME"
+ quarkusDataSourceDataIndexPassword =
"QUARKUS_DATASOURCE_DATAINDEX_PASSWORD"
+ quarkusFlywayDataIndexSchemas = "QUARKUS_FLYWAY_DATAINDEX_SCHEMAS"
+
+ migrateDBJobsService = "MIGRATE_DB_JOBSSERVICE"
+ quarkusDataSourceJobsServiceJdbcURL =
"QUARKUS_DATASOURCE_JOBSSERVICE_JDBC_URL"
+ quarkusDataSourceJobsServiceUserName =
"QUARKUS_DATASOURCE_JOBSSERVICE_USERNAME"
+ quarkusDataSourceJobsServicePassword =
"QUARKUS_DATASOURCE_JOBSSERVICE_PASSWORD"
+ quarkusFlywayJobsServiceSchemas =
"QUARKUS_FLYWAY_JOBSSERVICE_SCHEMAS"
)
type DBMigrationJobCfg struct {
@@ -110,7 +103,7 @@ func getJdbcUrl(env []corev1.EnvVar) string {
func getQuarkusDSFromServicePersistence(platform
*operatorapi.SonataFlowPlatform, persistenceOptionsSpec
*operatorapi.PersistenceOptionsSpec, defaultSchemaName string)
*QuarkusDataSource {
klog.InfoS("Using service level persistence for PostgreSQL",
"defaultSchemaName", defaultSchemaName)
quarkusDataSource := &QuarkusDataSource{}
- env :=
persistence.ConfigurePostgreSQLEnv(persistenceOptionsSpec.PostgreSQL,
defaultSchemaName, platform.Namespace)
+ env :=
persistence.ConfigurePostgreSQLEnv(persistenceOptionsSpec.PostgreSQL,
defaultSchemaName, platform.Namespace, false)
quarkusDataSource.JdbcUrl = getJdbcUrl(env)
quarkusDataSource.SecretRefName =
persistenceOptionsSpec.PostgreSQL.SecretRef.Name
quarkusDataSource.SecretUserKey =
persistenceOptionsSpec.PostgreSQL.SecretRef.UserKey
@@ -125,7 +118,7 @@ func getQuarkusDSFromPlatformPersistence(platform
*operatorapi.SonataFlowPlatfor
quarkusDataSource := &QuarkusDataSource{}
postgresql := persistence.MapToPersistencePostgreSQL(platform,
defaultSchemaName)
- env := persistence.ConfigurePostgreSQLEnv(postgresql,
defaultSchemaName, platform.Namespace)
+ env := persistence.ConfigurePostgreSQLEnv(postgresql,
defaultSchemaName, platform.Namespace, false)
quarkusDataSource.JdbcUrl = getJdbcUrl(env)
quarkusDataSource.SecretRefName =
platform.Spec.Persistence.PostgreSQL.SecretRef.Name
quarkusDataSource.SecretUserKey =
platform.Spec.Persistence.PostgreSQL.SecretRef.UserKey
@@ -309,10 +302,6 @@ func createJobDBMigration(platform
*operatorapi.SonataFlowPlatform, dbmj *DBMigr
Name:
quarkusDataSourceDataIndexJdbcURL,
Value:
diQuarkusDataSource.JdbcUrl,
},
- {
- Name:
quarkusDataSourceDataIndexJdbcReactiveURL,
- Value:
diQuarkusDataSource.JdbcReactiveUrl(),
- },
{
Name:
quarkusDataSourceDataIndexUserName,
ValueFrom: &corev1.EnvVarSource{
@@ -343,10 +332,6 @@ func createJobDBMigration(platform
*operatorapi.SonataFlowPlatform, dbmj *DBMigr
Name:
quarkusDataSourceJobsServiceJdbcURL,
Value:
jsQuarkusDataSource.JdbcUrl,
},
- {
- Name:
quarkusDataSourceJobsServiceJdbcReactiveURL,
- Value:
jsQuarkusDataSource.JdbcReactiveUrl(),
- },
{
Name:
quarkusDataSourceJobsServiceUserName,
ValueFrom: &corev1.EnvVarSource{
diff --git
a/packages/sonataflow-operator/internal/controller/platform/db_migrator_job_test.go
b/packages/sonataflow-operator/internal/controller/platform/db_migrator_job_test.go
index 3df38121f10..bbf44ab82f7 100644
---
a/packages/sonataflow-operator/internal/controller/platform/db_migrator_job_test.go
+++
b/packages/sonataflow-operator/internal/controller/platform/db_migrator_job_test.go
@@ -55,7 +55,7 @@ func TestDbMigratorJob(t *testing.T) {
t.Run("verify data-index jdbc url", func(t *testing.T) {
ksp := getBaseSonataFlowPlatformInReadyPhase(t.Name())
- env :=
persistence.ConfigurePostgreSQLEnv(ksp.Spec.Services.DataIndex.Persistence.PostgreSQL,
"data-index-schema", ksp.Namespace)
+ env :=
persistence.ConfigurePostgreSQLEnv(ksp.Spec.Services.DataIndex.Persistence.PostgreSQL,
"data-index-schema", ksp.Namespace, false)
jdbcUrl := getJdbcUrl(env)
assert.Equal(t, jdbcUrl, DataIndexJdbcUrl)
diff --git
a/packages/sonataflow-operator/internal/controller/platform/services/properties_services_test.go
b/packages/sonataflow-operator/internal/controller/platform/services/properties_services_test.go
index 67af7665ec0..5709d5b53a9 100644
---
a/packages/sonataflow-operator/internal/controller/platform/services/properties_services_test.go
+++
b/packages/sonataflow-operator/internal/controller/platform/services/properties_services_test.go
@@ -132,7 +132,6 @@ func generateJobServiceDeploymentWithPostgreSQLProperties()
*properties.Properti
p.Set("quarkus.kogito.devservices.enabled", "false")
p.Set(`quarkus.smallrye-health.check."org.kie.kogito.jobs.service.messaging.http.health.knative.KSinkInjectionHealthCheck".enabled`,
"false")
p.Set(`quarkus.smallrye-health.check."io.quarkus.kafka.client.health.KafkaHealthCheck".enabled`,
"false")
- p.Set("quarkus.datasource.reactive.url",
"postgresql://postgres:5432/sonataflow?search_path=myschema")
p.Set(`quarkus.smallrye-health.check."org.kie.kogito.jobs.service.management.JobServiceLeaderLivenessHealthCheck".enabled`,
"true")
p.Set("kogito.jobs-service.management.leader-check.expiration-in-seconds", "60")
p.Sort()
@@ -167,7 +166,6 @@ func
generateJobServiceDeploymentWithDataIndexAndPostgreSQLProperties() *propert
p.Set("quarkus.kogito.devservices.enabled", "false")
p.Set(`quarkus.smallrye-health.check."org.kie.kogito.jobs.service.messaging.http.health.knative.KSinkInjectionHealthCheck".enabled`,
"false")
p.Set(`quarkus.smallrye-health.check."io.quarkus.kafka.client.health.KafkaHealthCheck".enabled`,
"false")
- p.Set("quarkus.datasource.reactive.url",
"postgresql://postgres:5432/sonataflow?search_path=myschema")
p.Set(`quarkus.smallrye-health.check."org.kie.kogito.jobs.service.management.JobServiceLeaderLivenessHealthCheck".enabled`,
"true")
p.Set("kogito.jobs-service.management.leader-check.expiration-in-seconds", "60")
p.Sort()
diff --git
a/packages/sonataflow-operator/internal/controller/platform/services/services.go
b/packages/sonataflow-operator/internal/controller/platform/services/services.go
index de1091bb72c..00f077c803f 100644
---
a/packages/sonataflow-operator/internal/controller/platform/services/services.go
+++
b/packages/sonataflow-operator/internal/controller/platform/services/services.go
@@ -291,7 +291,7 @@ func (d *DataIndexHandler)
ConfigurePersistence(containerSpec *corev1.Container)
p :=
persistence.RetrievePostgreSQLConfiguration(d.platform.Spec.Services.DataIndex.Persistence,
d.platform.Spec.Persistence, d.GetServiceName())
c := containerSpec.DeepCopy()
c.Image =
d.GetServiceImageName(constants.PersistenceTypePostgreSQL)
- c.Env = append(c.Env,
persistence.ConfigurePostgreSQLEnv(p.PostgreSQL, d.GetServiceName(),
d.platform.Namespace)...)
+ c.Env = append(c.Env,
persistence.ConfigurePostgreSQLEnv(p.PostgreSQL, d.GetServiceName(),
d.platform.Namespace, false)...)
dbMigrationStrategyService :=
isDBMigrationStrategyService(d.platform.Spec.Services.DataIndex.Persistence)
@@ -484,7 +484,7 @@ func (j *JobServiceHandler)
ConfigurePersistence(containerSpec *corev1.Container
c := containerSpec.DeepCopy()
c.Image =
j.GetServiceImageName(constants.PersistenceTypePostgreSQL)
p :=
persistence.RetrievePostgreSQLConfiguration(j.platform.Spec.Services.JobService.Persistence,
j.platform.Spec.Persistence, j.GetServiceName())
- c.Env = append(c.Env,
persistence.ConfigurePostgreSQLEnv(p.PostgreSQL, j.GetServiceName(),
j.platform.Namespace)...)
+ c.Env = append(c.Env,
persistence.ConfigurePostgreSQLEnv(p.PostgreSQL, j.GetServiceName(),
j.platform.Namespace, true)...)
dbMigrationStrategyService :=
isDBMigrationStrategyService(j.platform.Spec.Services.JobService.Persistence)
@@ -515,16 +515,6 @@ func (j *JobServiceHandler) GenerateServiceProperties()
(*properties.Properties,
props.Set(constants.JobServiceKSinkInjectionHealthCheck, "true")
}
- // add data source reactive URL
- if j.hasPostgreSQLConfigured() {
- p :=
persistence.RetrievePostgreSQLConfiguration(j.platform.Spec.Services.JobService.Persistence,
j.platform.Spec.Persistence, j.GetServiceName())
- dataSourceReactiveURL, err := generateReactiveURL(p.PostgreSQL,
j.GetServiceName(), j.platform.Namespace, constants.DefaultDatabaseName,
constants.DefaultPostgreSQLPort)
- if err != nil {
- return nil, err
- }
- props.Set(constants.JobServiceDataSourceReactiveURL,
dataSourceReactiveURL)
- }
-
if isDataIndexEnabled(j.platform) {
props.Set(constants.JobServiceStatusChangeEvents, "true")
if j.GetServiceSource() == nil {
diff --git
a/packages/sonataflow-operator/internal/controller/profiles/common/object_creators.go
b/packages/sonataflow-operator/internal/controller/profiles/common/object_creators.go
index 2e133926c90..f58164b4702 100644
---
a/packages/sonataflow-operator/internal/controller/profiles/common/object_creators.go
+++
b/packages/sonataflow-operator/internal/controller/profiles/common/object_creators.go
@@ -227,7 +227,7 @@ func defaultContainer(workflow *operatorapi.SonataFlow, plf
*operatorapi.SonataF
pper = plf.Spec.Persistence
}
if p :=
persistence.RetrieveConfiguration(workflow.Spec.Persistence, pper,
workflow.Name); p != nil {
- defaultFlowContainer =
persistence.ConfigurePersistence(defaultFlowContainer, p, workflow.Name,
workflow.Namespace)
+ defaultFlowContainer =
persistence.ConfigureWorkflowPersistence(defaultFlowContainer, p,
workflow.Name, workflow.Namespace)
}
}
// immutable
diff --git
a/packages/sonataflow-operator/internal/controller/profiles/common/object_creators_test.go
b/packages/sonataflow-operator/internal/controller/profiles/common/object_creators_test.go
index 02784798f77..70a50b55d8d 100644
---
a/packages/sonataflow-operator/internal/controller/profiles/common/object_creators_test.go
+++
b/packages/sonataflow-operator/internal/controller/profiles/common/object_creators_test.go
@@ -471,10 +471,6 @@ func TestMergePodSpec_WithPostgreSQL_and_JDBC_URL_field(t
*testing.T) {
Name: "QUARKUS_DATASOURCE_JDBC_URL",
Value:
"jdbc:postgresql://host:port/database?currentSchema=workflow",
},
- {
- Name: "QUARKUS_DATASOURCE_REACTIVE_URL",
- Value:
"postgresql://host:port/database?currentSchema=workflow",
- },
{
Name: "KOGITO_PERSISTENCE_TYPE",
Value: "jdbc",
@@ -559,10 +555,6 @@ func
TestMergePodSpec_OverrideContainers_WithPostgreSQL_In_Workflow_CR(t *testin
Name: "QUARKUS_DATASOURCE_JDBC_URL",
Value:
"jdbc:postgresql://test.foo:5432/petstore?currentSchema=bar",
},
- {
- Name: "QUARKUS_DATASOURCE_REACTIVE_URL",
- Value:
"postgresql://test.foo:5432/petstore?currentSchema=bar",
- },
{
Name: "KOGITO_PERSISTENCE_TYPE",
Value: "jdbc",
@@ -635,10 +627,6 @@ func
TestMergePodSpec_WithServicedPostgreSQL_In_Platform_CR_And_Worflow_Requesti
Name: "QUARKUS_DATASOURCE_JDBC_URL",
Value:
"jdbc:postgresql://service_name.service_namespace:5432/foo?currentSchema=greeting",
},
- {
- Name: "QUARKUS_DATASOURCE_REACTIVE_URL",
- Value:
"postgresql://service_name.service_namespace:5432/foo?currentSchema=greeting",
- },
{
Name: "KOGITO_PERSISTENCE_TYPE",
Value: "jdbc",
@@ -739,10 +727,6 @@ func
TestMergePodSpec_WithServicedPostgreSQL_In_Platform_And_In_Workflow_CR(t *t
Name: "QUARKUS_DATASOURCE_JDBC_URL",
Value:
"jdbc:postgresql://test.default:5432/my_database?currentSchema=bar",
},
- {
- Name: "QUARKUS_DATASOURCE_REACTIVE_URL",
- Value:
"postgresql://test.default:5432/my_database?currentSchema=bar",
- },
{
Name: "KOGITO_PERSISTENCE_TYPE",
Value: "jdbc",
@@ -960,10 +944,6 @@ func doTestDefaultContainer_WithPlatformPersistence(t
*testing.T, workflow *v1al
Name: "QUARKUS_DATASOURCE_JDBC_URL",
Value:
"jdbc:postgresql://service_name.service_namespace:5432/foo?currentSchema=greeting",
},
- {
- Name: "QUARKUS_DATASOURCE_REACTIVE_URL",
- Value:
"postgresql://service_name.service_namespace:5432/foo?currentSchema=greeting",
- },
{
Name: "KOGITO_PERSISTENCE_TYPE",
Value: "jdbc",
diff --git
a/packages/sonataflow-operator/internal/controller/profiles/common/persistence/postgresql.go
b/packages/sonataflow-operator/internal/controller/profiles/common/persistence/postgresql.go
index fad8db6d7d5..8ca7b8e12ea 100644
---
a/packages/sonataflow-operator/internal/controller/profiles/common/persistence/postgresql.go
+++
b/packages/sonataflow-operator/internal/controller/profiles/common/persistence/postgresql.go
@@ -38,7 +38,7 @@ const (
)
// ConfigurePostgreSQLEnv returns the common env variables required for the
DataIndex or JobsService when postresql persistence is used.
-func ConfigurePostgreSQLEnv(postgresql *operatorapi.PersistencePostgreSQL,
databaseSchema, databaseNamespace string) []corev1.EnvVar {
+func ConfigurePostgreSQLEnv(postgresql *operatorapi.PersistencePostgreSQL,
databaseSchema, databaseNamespace string, includeReactiveUrl bool)
[]corev1.EnvVar {
dataSourcePort := constants.DefaultPostgreSQLPort
databaseName := defaultDatabaseName
dataSourceURL := postgresql.JdbcUrl
@@ -57,9 +57,6 @@ func ConfigurePostgreSQLEnv(postgresql
*operatorapi.PersistencePostgreSQL, datab
}
dataSourceURL =
fmt.Sprintf("jdbc:postgresql://%s.%s:%d/%s?currentSchema=%s",
postgresql.ServiceRef.Name, databaseNamespace, dataSourcePort, databaseName,
databaseSchema)
}
-
- dataSourceReactiveURL := strings.TrimPrefix(dataSourceURL, "jdbc:")
-
secretRef := corev1.LocalObjectReference{
Name: postgresql.SecretRef.Name,
}
@@ -71,7 +68,7 @@ func ConfigurePostgreSQLEnv(postgresql
*operatorapi.PersistencePostgreSQL, datab
if len(postgresql.SecretRef.PasswordKey) > 0 {
quarkusDatasourcePassword = postgresql.SecretRef.PasswordKey
}
- return []corev1.EnvVar{
+ env := []corev1.EnvVar{
{
Name: "QUARKUS_DATASOURCE_USERNAME",
ValueFrom: &corev1.EnvVarSource{
@@ -98,23 +95,28 @@ func ConfigurePostgreSQLEnv(postgresql
*operatorapi.PersistencePostgreSQL, datab
Name: "QUARKUS_DATASOURCE_JDBC_URL",
Value: dataSourceURL,
},
- {
+ }
+ if includeReactiveUrl {
+ dataSourceReactiveURL := strings.TrimPrefix(dataSourceURL,
"jdbc:")
+ dataSourceReactiveURL =
strings.ReplaceAll(dataSourceReactiveURL, "currentSchema=", "search_path=")
+ env = append(env, corev1.EnvVar{
Name: "QUARKUS_DATASOURCE_REACTIVE_URL",
Value: dataSourceReactiveURL,
- },
- {
- Name: "KOGITO_PERSISTENCE_TYPE",
- Value: "jdbc",
- },
+ })
}
+ env = append(env, corev1.EnvVar{
+ Name: "KOGITO_PERSISTENCE_TYPE",
+ Value: "jdbc",
+ })
+ return env
}
-func ConfigurePersistence(serviceContainer *corev1.Container, config
*operatorapi.PersistenceOptionsSpec, defaultSchema, namespace string)
*corev1.Container {
+func ConfigureWorkflowPersistence(serviceContainer *corev1.Container, config
*operatorapi.PersistenceOptionsSpec, defaultSchema, namespace string)
*corev1.Container {
if config.PostgreSQL == nil {
return serviceContainer
}
c := serviceContainer.DeepCopy()
- c.Env = append(c.Env, ConfigurePostgreSQLEnv(config.PostgreSQL,
defaultSchema, namespace)...)
+ c.Env = append(c.Env, ConfigurePostgreSQLEnv(config.PostgreSQL,
defaultSchema, namespace, false)...)
return c
}
diff --git
a/packages/sonataflow-operator/internal/controller/sonataflowplatform_controller_test.go
b/packages/sonataflow-operator/internal/controller/sonataflowplatform_controller_test.go
index 370d3e8a50a..28bb81f0aa3 100644
---
a/packages/sonataflow-operator/internal/controller/sonataflowplatform_controller_test.go
+++
b/packages/sonataflow-operator/internal/controller/sonataflowplatform_controller_test.go
@@ -327,17 +327,13 @@ func TestSonataFlowPlatformController(t *testing.T) {
Name: "QUARKUS_DATASOURCE_JDBC_URL",
Value:
"jdbc:postgresql://postgresql.default:5432/sonataflow?currentSchema=sonataflow-platform-data-index-service",
}
- dbSourceDIReactiveURL := corev1.EnvVar{
- Name: "QUARKUS_DATASOURCE_REACTIVE_URL",
- Value:
"postgresql://postgresql.default:5432/sonataflow?currentSchema=sonataflow-platform-data-index-service",
- }
dbSourceJSURL := corev1.EnvVar{
Name: "QUARKUS_DATASOURCE_JDBC_URL",
Value:
"jdbc:postgresql://postgresql.default:5432/sonataflow?currentSchema=sonataflow-platform-jobs-service",
}
dbSourceJSReactiveURL := corev1.EnvVar{
Name: "QUARKUS_DATASOURCE_REACTIVE_URL",
- Value:
"postgresql://postgresql.default:5432/sonataflow?currentSchema=sonataflow-platform-jobs-service",
+ Value:
"postgresql://postgresql.default:5432/sonataflow?search_path=sonataflow-platform-jobs-service",
}
dbUsername := corev1.EnvVar{
Name: "QUARKUS_DATASOURCE_USERNAME",
@@ -369,7 +365,6 @@ func TestSonataFlowPlatformController(t *testing.T) {
assert.Contains(t, dep.Spec.Template.Spec.Containers[0].Env,
dbUsername)
assert.Contains(t, dep.Spec.Template.Spec.Containers[0].Env,
dbPassword)
assert.Contains(t, dep.Spec.Template.Spec.Containers[0].Env,
dbSourceDIURL)
- assert.Contains(t, dep.Spec.Template.Spec.Containers[0].Env,
dbSourceDIReactiveURL)
js := services.NewJobServiceHandler(ksp)
assert.NoError(t, cl.Get(context.TODO(),
types.NamespacedName{Name: js.GetServiceName(), Namespace: ksp.Namespace}, dep))
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
