pub async fn process_log_entries( log_entries: Vec<Log>, pools_config: &PoolsConfig, tasks_tx: Broadcaster<Task>, ) -> Result<()>