summaryrefslogtreecommitdiff
path: root/lib/Net/Riak/Role/PBC/MapReduce.pm
diff options
context:
space:
mode:
Diffstat (limited to 'lib/Net/Riak/Role/PBC/MapReduce.pm')
-rw-r--r--lib/Net/Riak/Role/PBC/MapReduce.pm5
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!";