def METHOD_NAME(self, *_, **__):
    job_config = CreateEventPublisherJob(
        name=self.config.serviceName,
        publisherType=PublisherType.elasticSearch,
        runMode=RunMode.batch,
        batchSize=self.source_config.batchSize,
        searchIndexMappingLanguage=self.source_config.searchIndexMappingLanguage,
        entities=self.service_connection.entities,
        recreateIndex=self.source_config.recreateIndex,
    )
    self.create_reindex_job(job_config)
    if self.reindex_job:
        self.log_reindex_status()
    yield from []  # nothing to yield