Skip to content

Commit aefb948

Browse files
feat: [google-cloud-dataproc] add session and session_template controllers (#12228)
- [ ] Regenerate this pull request now. PiperOrigin-RevId: 602428194 Source-Link: googleapis/googleapis@71ea538 Source-Link: googleapis/googleapis-gen@c4c4a52 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWRhdGFwcm9jLy5Pd2xCb3QueWFtbCIsImgiOiJjNGM0YTUyYzRiYmQ1Zjc5ZjFmMjkwNzcyNTA3MzUzZmViZTI1M2I0In0= --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
1 parent 4ea46b2 commit aefb948

57 files changed

Lines changed: 28579 additions & 23 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

packages/google-cloud-dataproc/docs/dataproc_v1/services_.rst

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,4 +8,6 @@ Services for Google Cloud Dataproc v1 API
88
cluster_controller
99
job_controller
1010
node_group_controller
11+
session_controller
12+
session_template_controller
1113
workflow_template_service
Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
SessionController
2+
-----------------------------------
3+
4+
.. automodule:: google.cloud.dataproc_v1.services.session_controller
5+
:members:
6+
:inherited-members:
7+
8+
.. automodule:: google.cloud.dataproc_v1.services.session_controller.pagers
9+
:members:
10+
:inherited-members:
Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
SessionTemplateController
2+
-------------------------------------------
3+
4+
.. automodule:: google.cloud.dataproc_v1.services.session_template_controller
5+
:members:
6+
:inherited-members:
7+
8+
.. automodule:: google.cloud.dataproc_v1.services.session_template_controller.pagers
9+
:members:
10+
:inherited-members:

packages/google-cloud-dataproc/google/cloud/dataproc/__init__.py

Lines changed: 56 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,18 @@
4646
from google.cloud.dataproc_v1.services.node_group_controller.client import (
4747
NodeGroupControllerClient,
4848
)
49+
from google.cloud.dataproc_v1.services.session_controller.async_client import (
50+
SessionControllerAsyncClient,
51+
)
52+
from google.cloud.dataproc_v1.services.session_controller.client import (
53+
SessionControllerClient,
54+
)
55+
from google.cloud.dataproc_v1.services.session_template_controller.async_client import (
56+
SessionTemplateControllerAsyncClient,
57+
)
58+
from google.cloud.dataproc_v1.services.session_template_controller.client import (
59+
SessionTemplateControllerClient,
60+
)
4961
from google.cloud.dataproc_v1.services.workflow_template_service.async_client import (
5062
WorkflowTemplateServiceAsyncClient,
5163
)
@@ -157,6 +169,26 @@
157169
ClusterOperationMetadata,
158170
ClusterOperationStatus,
159171
NodeGroupOperationMetadata,
172+
SessionOperationMetadata,
173+
)
174+
from google.cloud.dataproc_v1.types.session_templates import (
175+
CreateSessionTemplateRequest,
176+
DeleteSessionTemplateRequest,
177+
GetSessionTemplateRequest,
178+
ListSessionTemplatesRequest,
179+
ListSessionTemplatesResponse,
180+
SessionTemplate,
181+
UpdateSessionTemplateRequest,
182+
)
183+
from google.cloud.dataproc_v1.types.sessions import (
184+
CreateSessionRequest,
185+
DeleteSessionRequest,
186+
GetSessionRequest,
187+
JupyterConfig,
188+
ListSessionsRequest,
189+
ListSessionsResponse,
190+
Session,
191+
TerminateSessionRequest,
160192
)
161193
from google.cloud.dataproc_v1.types.shared import (
162194
Component,
@@ -169,6 +201,8 @@
169201
KubernetesClusterConfig,
170202
KubernetesSoftwareConfig,
171203
PeripheralsConfig,
204+
PyPiRepositoryConfig,
205+
RepositoryConfig,
172206
RuntimeConfig,
173207
RuntimeInfo,
174208
SparkHistoryServerConfig,
@@ -210,6 +244,10 @@
210244
"JobControllerAsyncClient",
211245
"NodeGroupControllerClient",
212246
"NodeGroupControllerAsyncClient",
247+
"SessionControllerClient",
248+
"SessionControllerAsyncClient",
249+
"SessionTemplateControllerClient",
250+
"SessionTemplateControllerAsyncClient",
213251
"WorkflowTemplateServiceClient",
214252
"WorkflowTemplateServiceAsyncClient",
215253
"AutoscalingPolicy",
@@ -306,6 +344,22 @@
306344
"ClusterOperationMetadata",
307345
"ClusterOperationStatus",
308346
"NodeGroupOperationMetadata",
347+
"SessionOperationMetadata",
348+
"CreateSessionTemplateRequest",
349+
"DeleteSessionTemplateRequest",
350+
"GetSessionTemplateRequest",
351+
"ListSessionTemplatesRequest",
352+
"ListSessionTemplatesResponse",
353+
"SessionTemplate",
354+
"UpdateSessionTemplateRequest",
355+
"CreateSessionRequest",
356+
"DeleteSessionRequest",
357+
"GetSessionRequest",
358+
"JupyterConfig",
359+
"ListSessionsRequest",
360+
"ListSessionsResponse",
361+
"Session",
362+
"TerminateSessionRequest",
309363
"EnvironmentConfig",
310364
"ExecutionConfig",
311365
"GkeClusterConfig",
@@ -314,6 +368,8 @@
314368
"KubernetesClusterConfig",
315369
"KubernetesSoftwareConfig",
316370
"PeripheralsConfig",
371+
"PyPiRepositoryConfig",
372+
"RepositoryConfig",
317373
"RuntimeConfig",
318374
"RuntimeInfo",
319375
"SparkHistoryServerConfig",

packages/google-cloud-dataproc/google/cloud/dataproc/gapic_version.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,4 +13,4 @@
1313
# See the License for the specific language governing permissions and
1414
# limitations under the License.
1515
#
16-
__version__ = "5.8.0" # {x-release-please-version}
16+
__version__ = "0.0.0" # {x-release-please-version}

packages/google-cloud-dataproc/google/cloud/dataproc_v1/__init__.py

Lines changed: 52 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,14 @@
3232
NodeGroupControllerAsyncClient,
3333
NodeGroupControllerClient,
3434
)
35+
from .services.session_controller import (
36+
SessionControllerAsyncClient,
37+
SessionControllerClient,
38+
)
39+
from .services.session_template_controller import (
40+
SessionTemplateControllerAsyncClient,
41+
SessionTemplateControllerClient,
42+
)
3543
from .services.workflow_template_service import (
3644
WorkflowTemplateServiceAsyncClient,
3745
WorkflowTemplateServiceClient,
@@ -141,6 +149,26 @@
141149
ClusterOperationMetadata,
142150
ClusterOperationStatus,
143151
NodeGroupOperationMetadata,
152+
SessionOperationMetadata,
153+
)
154+
from .types.session_templates import (
155+
CreateSessionTemplateRequest,
156+
DeleteSessionTemplateRequest,
157+
GetSessionTemplateRequest,
158+
ListSessionTemplatesRequest,
159+
ListSessionTemplatesResponse,
160+
SessionTemplate,
161+
UpdateSessionTemplateRequest,
162+
)
163+
from .types.sessions import (
164+
CreateSessionRequest,
165+
DeleteSessionRequest,
166+
GetSessionRequest,
167+
JupyterConfig,
168+
ListSessionsRequest,
169+
ListSessionsResponse,
170+
Session,
171+
TerminateSessionRequest,
144172
)
145173
from .types.shared import (
146174
Component,
@@ -153,6 +181,8 @@
153181
KubernetesClusterConfig,
154182
KubernetesSoftwareConfig,
155183
PeripheralsConfig,
184+
PyPiRepositoryConfig,
185+
RepositoryConfig,
156186
RuntimeConfig,
157187
RuntimeInfo,
158188
SparkHistoryServerConfig,
@@ -189,6 +219,8 @@
189219
"ClusterControllerAsyncClient",
190220
"JobControllerAsyncClient",
191221
"NodeGroupControllerAsyncClient",
222+
"SessionControllerAsyncClient",
223+
"SessionTemplateControllerAsyncClient",
192224
"WorkflowTemplateServiceAsyncClient",
193225
"AcceleratorConfig",
194226
"AutoscalingConfig",
@@ -217,12 +249,16 @@
217249
"CreateBatchRequest",
218250
"CreateClusterRequest",
219251
"CreateNodeGroupRequest",
252+
"CreateSessionRequest",
253+
"CreateSessionTemplateRequest",
220254
"CreateWorkflowTemplateRequest",
221255
"DataprocMetricConfig",
222256
"DeleteAutoscalingPolicyRequest",
223257
"DeleteBatchRequest",
224258
"DeleteClusterRequest",
225259
"DeleteJobRequest",
260+
"DeleteSessionRequest",
261+
"DeleteSessionTemplateRequest",
226262
"DeleteWorkflowTemplateRequest",
227263
"DiagnoseClusterRequest",
228264
"DiagnoseClusterResults",
@@ -239,6 +275,8 @@
239275
"GetClusterRequest",
240276
"GetJobRequest",
241277
"GetNodeGroupRequest",
278+
"GetSessionRequest",
279+
"GetSessionTemplateRequest",
242280
"GetWorkflowTemplateRequest",
243281
"GkeClusterConfig",
244282
"GkeNodePoolConfig",
@@ -259,6 +297,7 @@
259297
"JobReference",
260298
"JobScheduling",
261299
"JobStatus",
300+
"JupyterConfig",
262301
"KerberosConfig",
263302
"KubernetesClusterConfig",
264303
"KubernetesSoftwareConfig",
@@ -271,6 +310,10 @@
271310
"ListClustersResponse",
272311
"ListJobsRequest",
273312
"ListJobsResponse",
313+
"ListSessionTemplatesRequest",
314+
"ListSessionTemplatesResponse",
315+
"ListSessionsRequest",
316+
"ListSessionsResponse",
274317
"ListWorkflowTemplatesRequest",
275318
"ListWorkflowTemplatesResponse",
276319
"LoggingConfig",
@@ -287,15 +330,22 @@
287330
"PeripheralsConfig",
288331
"PigJob",
289332
"PrestoJob",
333+
"PyPiRepositoryConfig",
290334
"PySparkBatch",
291335
"PySparkJob",
292336
"QueryList",
293337
"RegexValidation",
338+
"RepositoryConfig",
294339
"ReservationAffinity",
295340
"ResizeNodeGroupRequest",
296341
"RuntimeConfig",
297342
"RuntimeInfo",
298343
"SecurityConfig",
344+
"Session",
345+
"SessionControllerClient",
346+
"SessionOperationMetadata",
347+
"SessionTemplate",
348+
"SessionTemplateControllerClient",
299349
"ShieldedInstanceConfig",
300350
"SoftwareConfig",
301351
"SparkBatch",
@@ -310,10 +360,12 @@
310360
"StopClusterRequest",
311361
"SubmitJobRequest",
312362
"TemplateParameter",
363+
"TerminateSessionRequest",
313364
"TrinoJob",
314365
"UpdateAutoscalingPolicyRequest",
315366
"UpdateClusterRequest",
316367
"UpdateJobRequest",
368+
"UpdateSessionTemplateRequest",
317369
"UpdateWorkflowTemplateRequest",
318370
"UsageMetrics",
319371
"UsageSnapshot",

0 commit comments

Comments
 (0)