Class JobEvent (1.12.2)

JobEvent(mapping=None, *, ignore_unknown_fields=False, **kwargs)

The payload associated with Job logs that contains events describing jobs that have run within a Lake.

Attributes

NameDescription
message str
The log message.
job_id str
The unique id identifying the job.
start_time google.protobuf.timestamp_pb2.Timestamp
The time when the job started running.
end_time google.protobuf.timestamp_pb2.Timestamp
The time when the job ended running.
state google.cloud.dataplex_v1.types.JobEvent.State
The job state on completion.
retries int
The number of retries.
type_ google.cloud.dataplex_v1.types.JobEvent.Type
The type of the job.
service google.cloud.dataplex_v1.types.JobEvent.Service
The service used to execute the job.
service_job str
The reference to the job within the service.
execution_trigger google.cloud.dataplex_v1.types.JobEvent.ExecutionTrigger
Job execution trigger.

Classes

ExecutionTrigger

ExecutionTrigger(value)

Job Execution trigger.

Values: EXECUTION_TRIGGER_UNSPECIFIED (0): The job execution trigger is unspecified. TASK_CONFIG (1): The job was triggered by Dataplex based on trigger spec from task definition. RUN_REQUEST (2): The job was triggered by the explicit call of Task API.

Service

Service(value)

The service used to execute the job.

Values: SERVICE_UNSPECIFIED (0): Unspecified service. DATAPROC (1): Cloud Dataproc.

State

State(value)

The completion status of the job.

Values: STATE_UNSPECIFIED (0): Unspecified job state. SUCCEEDED (1): Job successfully completed. FAILED (2): Job was unsuccessful. CANCELLED (3): Job was cancelled by the user. ABORTED (4): Job was cancelled or aborted via the service executing the job.

Type

Type(value)

The type of the job.

Values: TYPE_UNSPECIFIED (0): Unspecified job type. SPARK (1): Spark jobs. NOTEBOOK (2): Notebook jobs.