Method processQuery

src/Server/StatelessWorker/StatelessWorkerEndpoint.cpp:199–336

}

void StatelessWorkerEndpoint::processQuery(const HTMLForm & params, ReadBufferPtr body, WriteBuffer & out, HTTPServerResponse & response)
{
    auto operation = params.get("operation");
    auto task_id = params.get("task_id");

    if (operation == "start")
    {
        auto unique_temp_file_path = params.get("temp_path");
        /// Deserialize task fields from the request body
        DistributedQueryTaskDescription task_description;
        deserializeTask(task_description, *body);
        body->eof();
        body.reset();

        /// Pass it to the runner to start execution
        task_runner->startTask(task_id, task_description, unique_temp_file_path);
    }
    else if (operation == "get_status")
    {
        UInt64 wait_milliseconds = 0;
        if (params.has("wait_for_ms"))
            wait_milliseconds = parse<UInt64>(params.get("wait_for_ms"));

        UInt64 client_version = DBMS_MIN_PROTOCOL_VERSION_WITH_SERVER_QUERY_TIME_IN_PROGRESS;
        if (params.has("client_version"))
            client_version = parse<UInt64>(params.get("client_version"));

        body->eof();
        body.reset();

        auto status = task_runner->getStatus(task_id, wait_milliseconds);
        DistributedQueryTaskStatus task_status;
        task_status.progress = std::move(status.progress);

        switch (status.result)
        {
            case StatelessTaskExecutor::TaskRunnig:
            {
                response.setStatus(Poco::Net::HTTPResponse::HTTP_OK);
                task_status.status = "Running";
                break;
            }
            case StatelessTaskExecutor::TaskFinished:
            {
                response.setStatus(Poco::Net::HTTPResponse::HTTP_OK);
                task_status.status = "Finished";
                break;
            }
            case StatelessTaskExecutor::TaskCancelled:
            {
                response.setStatus(Poco::Net::HTTPResponse::HTTP_OK);
                task_status.status = "Cancelled";
                break;
            }
            case StatelessTaskExecutor::TaskFailed:
            {
                response.setStatus(Poco::Net::HTTPResponse::HTTP_OK);
                task_status.status = "Failed";