Method getStatus

src/Server/StatelessWorker/StatelessTaskExecutor.cpp:149–175

}

StatelessTaskExecutor::TaskStatus StatelessTaskExecutor::getStatus(const String & task_id, UInt64 wait_milliseconds)
{
    /// Make a copy of task completion future to wait for it outside of the lock
    std::shared_future<String> completion_future;
    std::shared_ptr<Progress> progress;
    {
        std::lock_guard lock(tasks_mutex);
        auto it = tasks.find(task_id);
        if (it == tasks.end())
            return TaskStatus{Result::UnknownTaskId, "", {}};
        completion_future = it->second->completion_future;
        progress = it->second->progress;
    }

    if (completion_future.valid() && completion_future.wait_for(std::chrono::milliseconds(wait_milliseconds)) == std::future_status::timeout)
    {
        Progress progress_delta = progress->fetchAndResetPiecewiseAtomically();
        return TaskStatus{Result::TaskRunnig, "", std::move(progress_delta)};
    }

    Progress progress_delta = progress->fetchAndResetPiecewiseAtomically();
    auto error_message = completion_future.get();
    if (error_message.empty())
        return TaskStatus{Result::TaskFinished, "", std::move(progress_delta)};
    else
        return TaskStatus{Result::TaskFailed, error_message, std::move(progress_delta)};
}

StatelessTaskExecutor::Result StatelessTaskExecutor::cancelTask(const String & task_id)
{