diff options
| author | Robin Edwards <robin.ge@gmail.com> | 2013-03-20 12:15:29 +0000 |
|---|---|---|
| committer | Robin Edwards <robin.ge@gmail.com> | 2013-03-20 12:22:48 +0000 |
| commit | 6910b7be19c747c5b8044a58c1877272530957db (patch) | |
| tree | 810c1a9d019b171004b238497d6fe96f928a5257 /lib/Net/Riak/Role/PBC/MapReduce.pm | |
| parent | Bump version for release (diff) | |
| download | net-riak-6910b7be19c747c5b8044a58c1877272530957db.tar.gz | |
Clean up ws
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!"; |