* Avoid race condition when streaming deleted statuses * Move redis lock to DistributionWorker to avoid extra Redis value