channel name

charts/quality-trace/values.yaml

@@ -77,7 +77,7 @@ telemetry:
         type: collector
         collector:
           # endpoint to send traces to the collector
-          endpoint: quality-trace-otel-collector:4317
+          endpoint: otel-collector:4317
 
 # Configures the server
 server:
@@ -103,7 +103,7 @@ image:
   repository: ghcr.io/intelops/quality-trace
   pullPolicy: IfNotPresent
   # Overrides the image tag whose default is the chart appVersion.
-  tag: pr-54
+  tag: latest
 
 env:
   qualitytraceDev: ""

server/app/app.go

@@ -139,7 +139,6 @@ func (app *App) Start(opts ...appOption) error {
 	}
 	fmt.Println(app.Version())
 	fmt.Println("Starting")
-	fmt.Println("inside app.go")
 	ctx := context.Background()
 
 	poolcfg, err := pgxpool.ParseConfig(app.cfg.PostgresConnString())

server/executor/queue_driver_postgres.go

@@ -84,6 +84,7 @@ func (qd *PostgresQueueDriver) Start() {
 func (qd *PostgresQueueDriver) worker(conn *pgxpool.Conn) {
 	qd.log("listening for notifications")
 	_, err := conn.Exec(context.Background(), "listen "+pgChannelName)
+	qd.log("channel name = %v", pgChannelName  )
 	if err != nil {
 		qd.log("error listening for notifications: %s", err.Error())
 		return

server/testdb/postgres.go

@@ -23,7 +23,6 @@ func Postgres(options ...PostgresOption) (*postgresDB, error) {
 			return nil, err
 		}
 	}
-	fmt.Println("checking migration")
 	err := ps.ensureLatestMigration()
 	if err != nil {
 		return nil, fmt.Errorf("could not execute migrations: %w", err)
@@ -34,7 +33,6 @@ func Postgres(options ...PostgresOption) (*postgresDB, error) {
 
 func (p *postgresDB) ensureLatestMigration() error {
 	driver, err := postgres.WithInstance(p.db, &postgres.Config{})
-	fmt.Printf(" db name = %v, config= %v", p.db,postgres.Config{} )
 	if err != nil {
 		return fmt.Errorf("could not get driver from postgres connection: %w", err)
 	}