diff options
Diffstat (limited to 'lib/Travelynx/Command/work.pm')
| -rw-r--r-- | lib/Travelynx/Command/work.pm | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/lib/Travelynx/Command/work.pm b/lib/Travelynx/Command/work.pm index 00dc27e..fbd70a6 100644 --- a/lib/Travelynx/Command/work.pm +++ b/lib/Travelynx/Command/work.pm @@ -36,6 +36,7 @@ sub run { } my $errors = 0; + my $backend_issues = 0; my $rate_limit_counts = 0; my $dbris_rate_limited = 0; @@ -144,6 +145,9 @@ sub run { $dbris_rate_limited = 1; $rate_limit_counts += 1; } + else { + $backend_issues += 1; + } } )->wait; @@ -263,6 +267,7 @@ sub run { )->catch( sub { my ($err) = @_; + $backend_issues += 1; if ( $err =~ m{svcResL\[0\][.]err is (?:FAIL|PARAMETER)$} ) { @@ -471,6 +476,7 @@ sub run { )->catch( sub { my ($error) = @_; + $backend_issues += 1; $self->app->log->error( "work($uid) @ IRIS: arrival: $error"); $errors += 1; @@ -494,12 +500,12 @@ sub run { if ( $self->app->mode eq 'development' ) { $self->app->log->debug( 'POST ' . $self->app->config->{influxdb}->{url} - . " worker runtime_seconds=${worker_duration},errors=${errors},ratelimit_count=${rate_limit_counts}" + . " worker runtime_seconds=${worker_duration},errors=${errors},backend_errors=${backend_issues},ratelimit_count=${rate_limit_counts}" ); } else { $self->app->ua->post_p( $self->app->config->{influxdb}->{url}, -"worker runtime_seconds=${worker_duration},errors=${errors},ratelimit_count=${rate_limit_counts}" +"worker runtime_seconds=${worker_duration},errors=${errors},backend_errors=${backend_issues},ratelimit_count=${rate_limit_counts}" )->wait; } } |