0
# Job Management
1
2
Long-running batch operations for processing large datasets, including scheduled triggers, hybrid content inspection, and comprehensive job lifecycle management for enterprise-scale data protection workflows.
3
4
## Capabilities
5
6
### DLP Job Operations
7
8
```python { .api }
9
def create_dlp_job(
10
request: dlp.CreateDlpJobRequest,
11
*,
12
parent: Optional[str] = None,
13
inspect_job: Optional[dlp.InspectJobConfig] = None,
14
risk_job: Optional[dlp.RiskAnalysisJobConfig] = None,
15
retry: OptionalRetry = gapic_v1.method.DEFAULT,
16
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
17
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
18
) -> dlp.DlpJob: ...
19
20
def get_dlp_job(
21
request: dlp.GetDlpJobRequest,
22
*,
23
name: Optional[str] = None,
24
retry: OptionalRetry = gapic_v1.method.DEFAULT,
25
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
26
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
27
) -> dlp.DlpJob: ...
28
29
def list_dlp_jobs(
30
request: dlp.ListDlpJobsRequest,
31
*,
32
parent: Optional[str] = None,
33
retry: OptionalRetry = gapic_v1.method.DEFAULT,
34
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
35
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
36
) -> pagers.ListDlpJobsPager: ...
37
38
def delete_dlp_job(
39
request: dlp.DeleteDlpJobRequest,
40
*,
41
name: Optional[str] = None,
42
retry: OptionalRetry = gapic_v1.method.DEFAULT,
43
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
44
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
45
) -> None: ...
46
47
def cancel_dlp_job(
48
request: dlp.CancelDlpJobRequest,
49
*,
50
retry: OptionalRetry = gapic_v1.method.DEFAULT,
51
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
52
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
53
) -> None: ...
54
55
def hybrid_inspect_dlp_job(
56
request: dlp.HybridInspectDlpJobRequest,
57
*,
58
retry: OptionalRetry = gapic_v1.method.DEFAULT,
59
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
60
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
61
) -> dlp.HybridInspectResponse: ...
62
63
def finish_dlp_job(
64
request: dlp.FinishDlpJobRequest,
65
*,
66
retry: OptionalRetry = gapic_v1.method.DEFAULT,
67
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
68
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
69
) -> None: ...
70
```
71
72
### Job Trigger Operations
73
74
```python { .api }
75
def create_job_trigger(
76
request: dlp.CreateJobTriggerRequest,
77
*,
78
parent: Optional[str] = None,
79
job_trigger: Optional[dlp.JobTrigger] = None,
80
retry: OptionalRetry = gapic_v1.method.DEFAULT,
81
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
82
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
83
) -> dlp.JobTrigger: ...
84
85
def update_job_trigger(
86
request: dlp.UpdateJobTriggerRequest,
87
*,
88
name: Optional[str] = None,
89
job_trigger: Optional[dlp.JobTrigger] = None,
90
update_mask: Optional[field_mask_pb2.FieldMask] = None,
91
retry: OptionalRetry = gapic_v1.method.DEFAULT,
92
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
93
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
94
) -> dlp.JobTrigger: ...
95
96
def get_job_trigger(
97
request: dlp.GetJobTriggerRequest,
98
*,
99
name: Optional[str] = None,
100
retry: OptionalRetry = gapic_v1.method.DEFAULT,
101
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
102
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
103
) -> dlp.JobTrigger: ...
104
105
def list_job_triggers(
106
request: dlp.ListJobTriggersRequest,
107
*,
108
parent: Optional[str] = None,
109
retry: OptionalRetry = gapic_v1.method.DEFAULT,
110
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
111
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
112
) -> pagers.ListJobTriggersPager: ...
113
114
def delete_job_trigger(
115
request: dlp.DeleteJobTriggerRequest,
116
*,
117
name: Optional[str] = None,
118
retry: OptionalRetry = gapic_v1.method.DEFAULT,
119
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
120
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
121
) -> None: ...
122
123
def activate_job_trigger(
124
request: dlp.ActivateJobTriggerRequest,
125
*,
126
retry: OptionalRetry = gapic_v1.method.DEFAULT,
127
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
128
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
129
) -> dlp.DlpJob: ...
130
131
def hybrid_inspect_job_trigger(
132
request: dlp.HybridInspectJobTriggerRequest,
133
*,
134
retry: OptionalRetry = gapic_v1.method.DEFAULT,
135
timeout: Union[float, object] = gapic_v1.method.DEFAULT,
136
metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
137
) -> dlp.HybridInspectResponse: ...
138
```
139
140
## Types
141
142
```python { .api }
143
class DlpJob:
144
"""Long-running DLP operation."""
145
146
name: str
147
type_: DlpJobType
148
state: DlpJob.JobState
149
risk_details: AnalyzeDataSourceRiskDetails
150
inspect_details: InspectDataSourceDetails
151
create_time: timestamp_pb2.Timestamp
152
start_time: timestamp_pb2.Timestamp
153
end_time: timestamp_pb2.Timestamp
154
last_modified: timestamp_pb2.Timestamp
155
job_trigger_name: str
156
errors: Sequence[Error]
157
158
class JobTrigger:
159
"""Scheduled DLP job configuration."""
160
161
name: str
162
display_name: str
163
description: str
164
inspect_job: InspectJobConfig
165
triggers: Sequence[JobTrigger.Trigger]
166
errors: Sequence[Error]
167
create_time: timestamp_pb2.Timestamp
168
update_time: timestamp_pb2.Timestamp
169
last_run_time: timestamp_pb2.Timestamp
170
status: JobTrigger.Status
171
172
class InspectJobConfig:
173
"""Configuration for inspection jobs."""
174
175
storage_config: StorageConfig
176
inspect_config: InspectConfig
177
inspect_template_name: str
178
actions: Sequence[Action]
179
180
class RiskAnalysisJobConfig:
181
"""Configuration for risk analysis jobs."""
182
183
privacy_metric: PrivacyMetric
184
source_table: BigQueryTable
185
actions: Sequence[Action]
186
```