@@ -41,13 +41,13 @@ func waitForSessionClosed(db *sql.DB) {
4141 session := ""
4242 err := db .QueryRow (
4343 "SELECT usename || ' ' || substring(query for 50) FROM pg_stat_activity WHERE " +
44- "usename IN ('evaluator', 'listener', 'vmaas_sync') LIMIT 30;" ,
44+ "usename IN ('manager', ' evaluator', 'listener', 'vmaas_sync') LIMIT 30;" ,
4545 ).Scan (& session )
4646 if err != nil {
4747 log .Info (err )
4848 }
4949 if session == "" {
50- log .Info ("No 'listener', 'evaluator', 'vmaas_sync' sessions found" )
50+ log .Info ("No 'manager', ' listener', 'evaluator', 'vmaas_sync' sessions found" )
5151 return
5252 }
5353 utils .LogInfo ("session:" , session , "Session found" )
@@ -67,12 +67,14 @@ func setPgEnv() {
6767
6868func blockUsers (db * sql.DB ) {
6969 execOrPanic (db , "ALTER USER listener NOLOGIN" )
70+ execOrPanic (db , "ALTER USER manager NOLOGIN" )
7071 execOrPanic (db , "ALTER USER evaluator NOLOGIN" )
7172 execOrPanic (db , "ALTER USER vmaas_sync NOLOGIN" )
7273}
7374
7475func unblockUsers (db * sql.DB ) {
7576 execOrPanic (db , "ALTER USER listener LOGIN" )
77+ execOrPanic (db , "ALTER USER manager LOGIN" )
7678 execOrPanic (db , "ALTER USER evaluator LOGIN" )
7779 execOrPanic (db , "ALTER USER vmaas_sync LOGIN" )
7880}
0 commit comments