1 files changed, 2 insertions, 1 deletions
diff --git a/lib/PublicInbox/LeiImportKw.pm b/lib/PublicInbox/LeiImportKw.pm
index 2878cbdf..402125cf 100644
--- a/lib/PublicInbox/LeiImportKw.pm
+++ b/lib/PublicInbox/LeiImportKw.pm
@@ -13,6 +13,7 @@ sub new {
          my $self = bless { -wq_ident => 'lei import_kw worker' }, $cls;
          my ($op_c, $ops) = $lei->workers_start($self, $self->detect_nproc);
          $op_c->{ops} = $ops; # for PktOp->event_step
+        $self->{lei_sock} = $lei->{sock};
          $lei->{ikw} = $self;
  }
  
@@ -42,13 +43,13 @@ sub ck_update_kw { # via wq_io_do
  sub ikw_done_wait {
          my ($arg, $pid) = @_;
          my ($self, $lei) = @$arg;
-        my $wait = $lei->{sto}->ipc_do('done');
          $lei->can('wq_done_wait')->($arg, $pid);
  }
  
  sub _lei_wq_eof { # EOF callback for main lei daemon
          my ($lei) = @_;
          my $ikw = delete $lei->{ikw} or return $lei->fail;
+        $lei->sto_done_request($ikw->{lei_sock});
          $ikw->wq_wait_old(\&ikw_done_wait, $lei);
  }