Skip to content

Commit

Permalink
default station logs severity (#1301)
Browse files Browse the repository at this point in the history
* changed from error to warn

* check if its an already exist log

---------

Co-authored-by: daniel-davidd <daniel@ip-192-168-1-103.eu-central-1.compute.internal>
  • Loading branch information
daniel-davidd and daniel-davidd committed Sep 4, 2023
1 parent b7f3cdd commit 5fd178b
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion server/memphis_handlers_producers.go
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,11 @@ func (s *Server) createProducerDirectCommon(c *client, pName, pType, pConnection
var created bool
station, created, err = CreateDefaultStation(user.TenantName, s, pStationName, user.ID, user.Username, "", 0)
if err != nil {
serv.Errorf("[tenant: %v][user: %v]createProducerDirectCommon at CreateDefaultStation: creating default station error - producer %v at station %v: %v", user.TenantName, user.Username, pName, pStationName.external, err.Error())
if strings.Contains(err.Error(), "already exists") {
serv.Warnf("[tenant: %v][user: %v]createProducerDirectCommon at CreateDefaultStation: creating default station error - producer %v at station %v: %v", user.TenantName, user.Username, pName, pStationName.external, err.Error())
} else {
serv.Errorf("[tenant: %v][user: %v]createProducerDirectCommon at CreateDefaultStation: creating default station error - producer %v at station %v: %v", user.TenantName, user.Username, pName, pStationName.external, err.Error())
}
return false, false, err, models.Station{}
}
if created {
Expand Down

0 comments on commit 5fd178b

Please sign in to comment.