Compare commits

..
2 Commits
2 changed files with 8 additions and 10 deletions
+7 -9
View File
@@ -107,18 +107,16 @@ func NewConnection() *GraphQL {
panic("Invalid value for RETRIES_ENABLE")
}
retriesNumber, retriesNumberExists := os.LookupEnv("RETRIES_NUMBER")
if !retriesNumberExists {
panic("RETRIES_NUMBER environment variable is not set but RETRIES_ENABLE is")
}
g.RetriesNumber, err = strconv.Atoi(retriesNumber)
if err != nil {
panic("Invalid value for RETRIES_NUMBER")
if retriesNumberExists {
g.RetriesNumber, err = strconv.Atoi(retriesNumber)
if err != nil {
panic("Invalid value for RETRIES_NUMBER")
}
}
retriesDelay, retriesDelayExists := os.LookupEnv("RETRIES_DELAY")
if !retriesDelayExists {
panic("RETRIES_DELAY environment variable is not set but RETRIES_ENABLE is")
if retriesDelayExists {
g.RetriesDelay, err = strconv.Atoi(retriesDelay)
}
g.RetriesDelay, err = strconv.Atoi(retriesDelay)
}
return &g
}
+1 -1
View File
@@ -79,7 +79,7 @@ func (g *GraphQL) Query(queryContent string, queryVariables interface{}, queryHe
g.Log.Error("Unable to send the query", map[string]interface{}{"_error": err.Error()})
return err
}
if httpResponse.StatusCode >= 200 && httpResponse.StatusCode <= 204 {
if httpResponse.StatusCode <= 200 && httpResponse.StatusCode >= 204 {
return errors.New(fmt.Sprintf("%v", httpResponse.StatusCode))
}
return nil