diff --git a/developer/dependencies/postgres-init.sh b/developer/dependencies/postgres-init.sh index f8e0ded5a0b..6ecada98426 100755 --- a/developer/dependencies/postgres-init.sh +++ b/developer/dependencies/postgres-init.sh @@ -5,4 +5,6 @@ psql -v ON_ERROR_STOP=1 --username "$POSTGRES_USER" --dbname "$POSTGRES_DB" <<-E CREATE USER docker; CREATE DATABASE postgresv2; GRANT ALL PRIVILEGES ON DATABASE postgresv2 TO docker; -EOSQL \ No newline at end of file + CREATE DATABASE jobservice; + GRANT ALL PRIVILEGES ON DATABASE jobservice TO docker; +EOSQL diff --git a/e2e/setup/jobservice.yaml b/e2e/setup/jobservice.yaml index 32dc4b89e77..dc8d713a624 100644 --- a/e2e/setup/jobservice.yaml +++ b/e2e/setup/jobservice.yaml @@ -11,7 +11,7 @@ postgresConfig: port: 5432 user: postgres password: psw - dbname: postgres + dbname: jobservice sslmode: disable grpcPool: initialConnections: 5 diff --git a/internal/jobservice/server/server.go b/internal/jobservice/server/server.go index c846d8a50bb..06dedfa1443 100644 --- a/internal/jobservice/server/server.go +++ b/internal/jobservice/server/server.go @@ -56,7 +56,7 @@ func (s *JobServiceServer) GetJobStatus(ctx context.Context, opts *js.JobService FromMessageId: fromMessageId, } } - log.Infof("Subscribing %s-%s with messageId %s", opts.Queue, opts.JobSetId, fromMessageId) + log.Infof("Subscribing to queue %s jobset %s messageId %s", opts.Queue, opts.JobSetId, fromMessageId) } else { if err := s.jobRepository.UpdateJobSetDb(ctx, opts.Queue, opts.JobSetId, fromMessageId); err != nil { log.WithFields(requestFields).Warn(err)