Method executeOneTask

src/Statistics/AutoStatisticsManager.cpp:303–376

}

bool AutoStatisticsManager::executeOneTask(const std::shared_ptr<TaskInfo> & chosen_task)
{
    auto catalog = createCatalogAdaptor(context);

    auto uuid = chosen_task->getTableUUID();
    auto table_opt = catalog->getTableIdByUUID(uuid);

    if (!table_opt)
    {
        // uuid is invalid, possibly due to table is dropped
        auto err_msg = fmt::format(FMT_STRING("uuid {} is no longer valid, skip auto stats task"), toString(uuid));
        LOG_WARNING(logger, err_msg);
        chosen_task->setStatus(Status::Failed);
        writeTaskLog(context, *chosen_task, err_msg);
        task_queue.erase(uuid);
        return true;
    }

    StatsTableIdentifier table = table_opt.value();
    try
    {
        LOG_INFO(logger, fmt::format(FMT_STRING("start auto stats on {}"), table.getNameForLogs()));

        chosen_task->setStatus(Status::Running);
        writeTaskLog(context, *chosen_task);

        auto settings = internal_config.collector_settings;
        auto columns_name = chosen_task->getColumnsName();

        if (!chosen_task->getSettingsJson().empty())
        {
            settings.fromJsonStr(chosen_task->getSettingsJson());
        }

        CollectTarget target(context, table, settings, columns_name);
        auto row_count_opt = collectStatsOnTarget(context, target);

        if (row_count_opt.has_value())
        {
            // normal execution finishes
            auto row_count = row_count_opt.value();
            LOG_INFO(logger, fmt::format(FMT_STRING("finish auto stats on {}"), table.getNameForLogs()));
            chosen_task->setStatus(Status::Success);
            chosen_task->setParams(0, row_count, 0);
            writeTaskLog(context, *chosen_task);
            task_queue.erase(uuid);
        }
        else
        {
            // trigger if_not_exists and skip collection due to stats exists
            // task is still successful
            LOG_INFO(logger, fmt::format(FMT_STRING("skip auto stats on {} since stats exists"), table.getNameForLogs()));
            chosen_task->setStatus(Status::Success);
            chosen_task->setParams(0, 0, 0);
            writeTaskLog(context, *chosen_task, "skip since stats exists");
            task_queue.erase(uuid);
        }