2 files changed, 5 insertions, 6 deletions
diff --git a/lib/presque/worker.pm b/lib/presque/worker.pm
index 89ecb83..12744bd 100644
--- a/lib/presque/worker.pm
+++ b/lib/presque/worker.pm
@@ -64,9 +64,11 @@ has rest_client => (
     isa     => 'Net::Presque',
     lazy    => 1,
     default => sub {
-        my $self = shift;
-        my $client =
-          Net::Presque->new(api_base_url => $self->context->{presque}->{url});
+        my $self   = shift;
+        my $client = Net::Presque->new(
+            api_base_url => $self->context->{presque}->{url},
+            worker_id    => $self->worker_id
+        );
         $client;
     },
     handles => {
diff --git a/lib/presque/worker/Role/Management.pm b/lib/presque/worker/Role/Management.pm
index d168311..2b02c57 100644
--- a/lib/presque/worker/Role/Management.pm
+++ b/lib/presque/worker/Role/Management.pm
@@ -18,21 +18,18 @@ after start => sub {
     my $self = shift;
     $self->unregister_worker(
         queue_name => $self->queue_name,
-        worker_id  => $self->worker_id
     );
 };
 after _graceful_shutdown => sub {
     my $self = shift;
     $self->unregister_worker(
         queue_name => $self->queue_name,
-        worker_id  => $self->worker_id
     );
 };
 after _shutdown => sub {
     my $self = shift;
     $self->unregister_worker(
         queue_name => $self->queue_name,
-        worker_id  => $self->worker_id
     );
 };