allow more retries and harden ratelimit for lufthansa

explore-flights · Jun 13, 2024 · aa3fdeb · aa3fdeb
1 parent e654e55
commit aa3fdeb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/go/common/lufthansa/client.go b/go/common/lufthansa/client.go
@@ -224,7 +224,7 @@ func doRequestFlightSchedules[T any](ctx context.Context, c *Client, airlines []
 
 	q.Set("timeMode", "UTC")
 
-	const maxRetries = 5
+	const maxRetries = 10
 	errs := make([]error, 0, maxRetries)
 
 	for len(errs) < maxRetries {
@@ -293,7 +293,7 @@ func doRequestPage[T pagedResource[D], D any](ctx context.Context, c *Client, me
 	q.Set("limit", strconv.Itoa(pageSize))
 	q.Set("offset", strconv.Itoa(offset))
 
-	const maxRetries = 5
+	const maxRetries = 10
 	errs := make([]error, 0, maxRetries)
 
 	for {

diff --git a/go/cron/main.go b/go/cron/main.go
@@ -52,7 +52,7 @@ func newHandler(s3c *s3.Client) func(ctx context.Context, event InputEvent) (jso
 	lhc := lufthansa.NewClient(
 		lhClientId,
 		lhClientSecret,
-		lufthansa.WithRateLimiter(rate.NewLimiter(rate.Every(time.Hour)*990, 3)),
+		lufthansa.WithRateLimiter(rate.NewLimiter(rate.Every(time.Hour)*490, 1)),
 	)
 
 	lCountriesAction := action.NewLoadMetadataAction(s3c, lhc, (*lufthansa.Client).CountriesRaw, "countries")