summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorBirte Kristina Friesel <derf@finalrewind.org>2025-06-29 05:48:05 +0200
committerBirte Kristina Friesel <derf@finalrewind.org>2025-06-29 05:48:05 +0200
commit3b80a60300472349630ce81fd8ca6534e9a24a20 (patch)
treef92aaba053a65de22fddf85fa1caa731752f6019
parentf136a53b56961d6a1704670198bf20a66917db9b (diff)
work: limit dbris journey requests to 0.5 Hz
If $backend is not set, we may have non-dbris checkins in between -- in that case, we don't need to wait as long
-rw-r--r--lib/Travelynx/Command/work.pm10
1 files changed, 6 insertions, 4 deletions
diff --git a/lib/Travelynx/Command/work.pm b/lib/Travelynx/Command/work.pm
index fa0a2ad..5ce7e8d 100644
--- a/lib/Travelynx/Command/work.pm
+++ b/lib/Travelynx/Command/work.pm
@@ -75,12 +75,14 @@ sub run {
eval {
- Mojo::Promise->timer( $dbris_rate_limited ? 4.5 : 1.0 )->then(
+ Mojo::Promise->timer(
+ $dbris_rate_limited ? 4.5 : ( $backend ? 2.0 : 1.0 ) )
+ ->then(
sub {
return $self->app->dbris->get_journey_p(
trip_id => $train_id );
}
- )->then(
+ )->then(
sub {
my ($journey) = @_;
@@ -173,7 +175,7 @@ sub run {
)->wait;
}
}
- )->catch(
+ )->catch(
sub {
my ($err) = @_;
$self->app->log->debug(
@@ -187,7 +189,7 @@ sub run {
$backend_issues += 1;
}
}
- )->wait;
+ )->wait;
if ( $arr
and $entry->{real_arr_ts}