diff options
Diffstat (limited to 'lib/Net/Riak/Role/PBC/MapReduce.pm')
-rw-r--r-- | lib/Net/Riak/Role/PBC/MapReduce.pm | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/lib/Net/Riak/Role/PBC/MapReduce.pm b/lib/Net/Riak/Role/PBC/MapReduce.pm index afeabe8..00e7de1 100644 --- a/lib/Net/Riak/Role/PBC/MapReduce.pm +++ b/lib/Net/Riak/Role/PBC/MapReduce.pm @@ -2,7 +2,6 @@ package Net::Riak::Role::PBC::MapReduce; use Moose::Role; use JSON; use List::Util 'sum'; -use Data::Dump 'pp'; sub execute_job { my ($self, $job, $timeout, $returned_phases) = @_; @@ -16,8 +15,8 @@ sub execute_job { my $resp = $self->send_message( MapRedReq => { request => $job_request, content_type => 'application/json' - }, sub { push @$results, $self->decode_phase(shift) }) - or + }, sub { push @$results, $self->decode_phase(shift) }) + or die "MapReduce query failed!"; |