.deploy/deploy-dev.yaml

@@ -6,8 +6,6 @@ services:
     image: mathwave/sprint-repo:queues
     networks:
       - queues-development
-    ports:
-      - 1239:1239
     environment:
       MONGO_HOST: "mongo.develop.sprinthub.ru"
       MONGO_PASSWORD: $MONGO_PASSWORD_DEV

app/routers/take.go

@@ -20,7 +20,6 @@ func Take(w http.ResponseWriter, r *http.Request) {
 	queue := r.Header.Get("queue")
 	task, err := tasks.Take(queue)
 	if err != nil {
-		println("Error taking")
 		w.WriteHeader(http.StatusInternalServerError)
 		return
 	}
@@ -38,7 +37,6 @@ func Take(w http.ResponseWriter, r *http.Request) {
 
 	data, err := json.Marshal(response)
 	if err != nil {
-		println("Error marshalling")
 		w.WriteHeader(http.StatusInternalServerError)
 		return
 	}

app/storage/mongo/collections/tasks.go

@@ -64,8 +64,6 @@ func Take(queue string) (*Task, error) {
 	}
 	_, err = collection().UpdateByID(context.TODO(), task.Id, bson.M{"$set": bson.M{"taken_at": now, "attempts": task.Attempts + 1}})
 	if err != nil {
-		println("Error updaing")
-		println(err.Error())
 		return nil, errors.ErrInternalError
 	}
 	return task, nil
@@ -80,16 +78,12 @@ func findTask(queue string, now time.Time) (*Task, error) {
 		},
 	)
 	if err != nil {
-		println("Error find")
-		println(err.Error())
 		return nil, errors.ErrInternalError
 	}
 
 	var results []Task
 	err = cursor.All(context.TODO(), &results)
 	if err != nil {
-		println("Error all")
-		println(err.Error())
 		return nil, errors.ErrInternalError
 	}