lib/PublicInbox/LEI.pm | 2 ++ diff --git a/lib/PublicInbox/LEI.pm b/lib/PublicInbox/LEI.pm index 8adf70faf2d70dbcf629e103bdf9fd589b2673da..0cf4d10b892b287eabbc6a14a50cb9d400791c00 100644 --- a/lib/PublicInbox/LEI.pm +++ b/lib/PublicInbox/LEI.pm @@ -580,6 +580,8 @@ my $ident = $wq->{-wq_ident} // "lei-$lei->{cmd} worker"; $wq->wq_workers_start($ident, $jobs, $lei->oldset, { lei => $lei }); delete $lei->{pkt_op_p}; my $op_c = delete $lei->{pkt_op_c}; + # {-lei_sock} persists script/lei process until ops->{''} EOF callback + $op_c->{-lei_sock} = $lei->{sock}; @$end = (); $lei->event_step_init; ($op_c, $ops);