Skip to content

Commit 133e017

Browse files
committed
Code cleanup for DB/ObjStore waiting functionality
1 parent ea490c4 commit 133e017

File tree

2 files changed

+10
-10
lines changed

2 files changed

+10
-10
lines changed

controllers/database.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -69,17 +69,17 @@ func (r *DSPAReconciler) isDatabaseAccessible(ctx context.Context, dsp *dspav1al
6969
}
7070

7171
decodePass, _ := b64.StdEncoding.DecodeString(params.DBConnection.Password)
72-
db_connect := ConnectAndQueryDatabase(params.DBConnection.Host,
72+
dbHealthCheckPassed := ConnectAndQueryDatabase(params.DBConnection.Host,
7373
params.DBConnection.Port,
7474
params.DBConnection.Username,
7575
string(decodePass),
7676
params.DBConnection.DBName)
77-
if db_connect {
77+
if dbHealthCheckPassed {
7878
log.Info("Database Health Check Successful")
7979
} else {
8080
log.Info("Unable to connect to Database")
8181
}
82-
return db_connect
82+
return dbHealthCheckPassed
8383
}
8484

8585
func (r *DSPAReconciler) ReconcileDatabase(ctx context.Context, dsp *dspav1alpha1.DataSciencePipelinesApplication,
@@ -92,11 +92,11 @@ func (r *DSPAReconciler) ReconcileDatabase(ctx context.Context, dsp *dspav1alpha
9292
// By default if Database is empty, we deploy mariadb
9393
externalDBSpecified := params.UsingExternalDB(dsp)
9494
mariaDBSpecified := dsp.Spec.Database.MariaDB != nil
95-
defaultDBRequired := (!databaseSpecified || (!externalDBSpecified && !mariaDBSpecified))
95+
defaultDBRequired := !databaseSpecified || (!externalDBSpecified && !mariaDBSpecified)
9696

97-
deployMariaDB := (mariaDBSpecified && dsp.Spec.Database.MariaDB.Deploy)
97+
deployMariaDB := mariaDBSpecified && dsp.Spec.Database.MariaDB.Deploy
9898
// Default DB is currently MariaDB as well, but storing these bools seperately in case that changes
99-
deployDefaultDB := (!databaseSpecified || defaultDBRequired)
99+
deployDefaultDB := !databaseSpecified || defaultDBRequired
100100

101101
// If external db is specified, it takes precedence
102102
if externalDBSpecified {

controllers/dspipeline_controller.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -221,9 +221,9 @@ func (r *DSPAReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.
221221
// Get Prereq Status (DB and ObjStore Ready)
222222
dbAvailable := r.isDatabaseAccessible(ctx, dspa, params)
223223
objStoreAvailable := r.isObjectStorageAccessible(ctx, dspa, params)
224-
dspa_prereqs_ready := (dbAvailable && objStoreAvailable)
224+
dspaPrereqsReady := (dbAvailable && objStoreAvailable)
225225

226-
if dspa_prereqs_ready {
226+
if dspaPrereqsReady {
227227
// Manage Common Manifests
228228
err = r.ReconcileCommon(dspa, params)
229229
if err != nil {
@@ -264,7 +264,7 @@ func (r *DSPAReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.
264264
return ctrl.Result{}, err
265265
}
266266

267-
conditions, err := r.GenerateStatus(ctx, dspa, params, dbAvailable, objStoreAvailable)
267+
conditions, err := r.GenerateStatus(ctx, dspa, dbAvailable, objStoreAvailable)
268268
if err != nil {
269269
log.Info(err.Error())
270270
return ctrl.Result{}, err
@@ -409,7 +409,7 @@ func (r *DSPAReconciler) handleReadyCondition(ctx context.Context, dspa *dspav1a
409409

410410
}
411411

412-
func (r *DSPAReconciler) GenerateStatus(ctx context.Context, dspa *dspav1alpha1.DataSciencePipelinesApplication, params *DSPAParams, dbAvailableStatus, objStoreAvailableStatus bool) ([]metav1.Condition, error) {
412+
func (r *DSPAReconciler) GenerateStatus(ctx context.Context, dspa *dspav1alpha1.DataSciencePipelinesApplication, dbAvailableStatus, objStoreAvailableStatus bool) ([]metav1.Condition, error) {
413413
// Create Database Availability Condition
414414
databaseAvailable := r.buildCondition(config.DatabaseAvailable, dspa, config.DatabaseAvailable)
415415
if dbAvailableStatus {

0 commit comments

Comments
 (0)