diff --git a/jobsdb/readonly_jobsdb.go b/jobsdb/readonly_jobsdb.go index 57aabfa165..ab0b4117ea 100644 --- a/jobsdb/readonly_jobsdb.go +++ b/jobsdb/readonly_jobsdb.go @@ -99,6 +99,8 @@ func (jd *ReadonlyHandleT) Setup(tablePrefix string) error { return fmt.Errorf("opening connection to db: %v", err) } + jd.DbHandle.SetMaxOpenConns(config.GetInt("ReadonlyJobsDB."+jd.tablePrefix+"."+"maxOpenConnections", config.GetInt("ReadonlyJobsDB.maxOpenConnections", 5))) + ctx, cancel := context.WithTimeout(context.TODO(), config.GetDuration("JobsDB.dbPingTimeout", 10, time.Second)) defer cancel() @@ -561,7 +563,7 @@ func (jd *ReadonlyHandleT) GetLatestFailedJobs(arg, prefix string) (string, erro job_latest_state.exec_time, job_latest_state.error_code, job_latest_state.error_response FROM %[1]s - JOIN "v_last_%[2]s" job_latest_state ON %[1]s.job_id=job_latest_state.job_id + JOIN "v_last_%[2]s" job_latest_state ON %[1]s.job_id=job_latest_state.job_id WHERE job_latest_state.job_state = 'failed' `, dsList.JobTableName, dsList.JobStatusTableName) if argList[1] != "" {