CronJobProgressHelper example

        return [
            'Shopware_CronJob_RefreshCustomerStreams' => 'refresh',
        ];
    }

    /** * @return bool */
    public function refresh()
    {
        $helper = new CronJobProgressHelper();

        $query = $this->createQuery();

        $this->connection->transactional(function D) use ($query) {
            $this->connection->executeUpdate('DELETE FROM s_customer_search_index');

            while ($ids = $query->fetch()) {
                $this->searchIndexer->populate($ids);
            }
        });