UpdateStatus

Currently used to update Job status.

TypeScript

import { cloudApi, serviceClients, Session } from "@yandex-cloud/nodejs-sdk";

const Job_Status = cloudApi.dataproc.manager_job.Job_Status;
const UpdateJobStatusRequest =
  cloudApi.dataproc.manager_job_service.UpdateJobStatusRequest;

(async () => {
  const authToken = process.env["YC_OAUTH_TOKEN"];
  const session = new Session({ oauthToken: authToken });
  const client = session.client(serviceClients.JobServiceClient);

  const result = await client.updateStatus(
    UpdateJobStatusRequest.fromPartial({
      // clusterId: "clusterId",
      // jobId: "jobId",
      // status: Job_Status.PROVISIONING,
      // applicationInfo: {
      // id: "id",
      // applicationAttempts: [{
      // id: "id",
      // amContainerId: "amContainerId"
      // }]
      // }
    })
  );
  console.log(result);
})();

Python

import os
import grpc
import yandexcloud

from yandex.cloud.dataproc.manager.v1.job_pb2 import ApplicationAttempt
from yandex.cloud.dataproc.manager.v1.job_pb2 import ApplicationInfo
from yandex.cloud.dataproc.manager.v1.job_service_pb2_grpc import JobServiceStub
from yandex.cloud.dataproc.manager.v1.job_service_pb2 import UpdateJobStatusRequest

token = os.getenv("YC_OAUTH_TOKEN")

sdk = yandexcloud.SDK(token=token)

service = sdk.client(JobServiceStub)
response = service.UpdateStatus(
    UpdateJobStatusRequest(
        # cluster_id = "clusterId",
        # job_id = "jobId",
        # status = Job.Status.PROVISIONING,
        # application_info = ApplicationInfo(
        # id = "id",
        # application_attempts = [ApplicationAttempt(
        # id = "id",
        # am_container_id = "amContainerId"
        # )]
        # )
    )
)
print(response)

UpdateJobStatusRequest

clusterId : string

Required. ID of the Data Proc cluster.

jobId : string

Required. ID of the Data Proc job to update.

status : Job.Status

Required. New status of the job.

applicationInfo : ApplicationInfo

Attributes of YARN application.

ApplicationInfo

id : string

ID of YARN application

applicationAttempts : ApplicationAttempt

YARN application attempts

ApplicationAttempt

id : string

ID of YARN application attempt

amContainerId : string

ID of YARN Application Master container

UpdateJobStatusResponse

---