Skip to content
Permalink
Browse files
chore: upgrade gapic-generator-python to 0.46.3 (#188)
feat: update the Dataproc V1 API client library
    This includes the following:
    1. The new start and stop cluster methods.
    2. The ability to specify a metastore config in a cluster.
    3. The ability to specify a (BETA) GKE cluster when creating a Dataproc cluster.
    4. The ability to configure the behavior for private IPv6 cluster networking.
    5. The ability to specify node affinity groups for clusters.
    6. The ability to specify shielded VM configurations for clusters.
    7. Support for service-account based secure multi-tenancy.
    8. The ability to specify cluster labels for picking which cluster should run a job.
    9. Components for DOCKER, DRUID, FLINK, HBASE, RANGER, and SOLR
    10. The ability to specify a DAG timeout for workflows.

feat: support self-signed JWT flow for service accounts

fix: add async client to %name_%version/init.py

chore: add autogenerated snippets

chore: remove auth, policy, and options from the reserved names list

chore: enable GAPIC metadata generation

chore: sort subpackages in %namespace/%name/init.py
  • Loading branch information
gcf-owl-bot committed May 20, 2021
1 parent c1ee50b commit 5137a6fce856b22be884aae19ec814458fc4ce97
Showing with 6,592 additions and 4,379 deletions.
  1. 0 dataproc-v1beta2-py.tar.gz
  2. +0 −1 docs/dataproc_v1/autoscaling_policy_service.rst
  3. +0 −1 docs/dataproc_v1/cluster_controller.rst
  4. +0 −1 docs/dataproc_v1/job_controller.rst
  5. +0 −1 docs/dataproc_v1/workflow_template_service.rst
  6. +0 −1 docs/dataproc_v1beta2/autoscaling_policy_service.rst
  7. +0 −1 docs/dataproc_v1beta2/cluster_controller.rst
  8. +0 −1 docs/dataproc_v1beta2/job_controller.rst
  9. +0 −1 docs/dataproc_v1beta2/workflow_template_service.rst
  10. +72 −58 google/cloud/dataproc/__init__.py
  11. +24 −3 google/cloud/dataproc_v1/__init__.py
  12. +335 −0 google/cloud/dataproc_v1/gapic_metadata.json
  13. +0 −1 google/cloud/dataproc_v1/services/__init__.py
  14. +0 −2 google/cloud/dataproc_v1/services/autoscaling_policy_service/__init__.py
  15. +14 −29 google/cloud/dataproc_v1/services/autoscaling_policy_service/async_client.py
  16. +32 −44 google/cloud/dataproc_v1/services/autoscaling_policy_service/client.py
  17. +1 −3 google/cloud/dataproc_v1/services/autoscaling_policy_service/pagers.py
  18. +0 −2 google/cloud/dataproc_v1/services/autoscaling_policy_service/transports/__init__.py
  19. +100 −37 google/cloud/dataproc_v1/services/autoscaling_policy_service/transports/base.py
  20. +16 −14 google/cloud/dataproc_v1/services/autoscaling_policy_service/transports/grpc.py
  21. +15 −15 google/cloud/dataproc_v1/services/autoscaling_policy_service/transports/grpc_asyncio.py
  22. +0 −2 google/cloud/dataproc_v1/services/cluster_controller/__init__.py
  23. +138 −41 google/cloud/dataproc_v1/services/cluster_controller/async_client.py
  24. +172 −49 google/cloud/dataproc_v1/services/cluster_controller/client.py
  25. +1 −3 google/cloud/dataproc_v1/services/cluster_controller/pagers.py
  26. +0 −2 google/cloud/dataproc_v1/services/cluster_controller/transports/__init__.py
  27. +134 −45 google/cloud/dataproc_v1/services/cluster_controller/transports/base.py
  28. +72 −20 google/cloud/dataproc_v1/services/cluster_controller/transports/grpc.py
  29. +74 −21 google/cloud/dataproc_v1/services/cluster_controller/transports/grpc_asyncio.py
  30. +0 −2 google/cloud/dataproc_v1/services/job_controller/__init__.py
  31. +29 −42 google/cloud/dataproc_v1/services/job_controller/async_client.py
  32. +30 −47 google/cloud/dataproc_v1/services/job_controller/client.py
  33. +1 −3 google/cloud/dataproc_v1/services/job_controller/pagers.py
  34. +0 −2 google/cloud/dataproc_v1/services/job_controller/transports/__init__.py
  35. +112 −53 google/cloud/dataproc_v1/services/job_controller/transports/base.py
  36. +17 −17 google/cloud/dataproc_v1/services/job_controller/transports/grpc.py
  37. +19 −18 google/cloud/dataproc_v1/services/job_controller/transports/grpc_asyncio.py
  38. +0 −2 google/cloud/dataproc_v1/services/workflow_template_service/__init__.py
  39. +39 −46 google/cloud/dataproc_v1/services/workflow_template_service/async_client.py
  40. +70 −55 google/cloud/dataproc_v1/services/workflow_template_service/client.py
  41. +1 −3 google/cloud/dataproc_v1/services/workflow_template_service/pagers.py
  42. +0 −2 google/cloud/dataproc_v1/services/workflow_template_service/transports/__init__.py
  43. +120 −50 google/cloud/dataproc_v1/services/workflow_template_service/transports/base.py
  44. +20 −19 google/cloud/dataproc_v1/services/workflow_template_service/transports/grpc.py
  45. +19 −20 google/cloud/dataproc_v1/services/workflow_template_service/transports/grpc_asyncio.py
  46. +14 −2 google/cloud/dataproc_v1/types/__init__.py
  47. +21 −43 google/cloud/dataproc_v1/types/autoscaling_policies.py
  48. +362 −219 google/cloud/dataproc_v1/types/clusters.py
  49. +110 −212 google/cloud/dataproc_v1/types/jobs.py
  50. +10 −25 google/cloud/dataproc_v1/types/operations.py
  51. +9 −3 google/cloud/dataproc_v1/types/shared.py
  52. +82 −122 google/cloud/dataproc_v1/types/workflow_templates.py
  53. +10 −3 google/cloud/dataproc_v1beta2/__init__.py
  54. +315 −0 google/cloud/dataproc_v1beta2/gapic_metadata.json
  55. +0 −1 google/cloud/dataproc_v1beta2/services/__init__.py
  56. +0 −2 google/cloud/dataproc_v1beta2/services/autoscaling_policy_service/__init__.py
  57. +14 −29 google/cloud/dataproc_v1beta2/services/autoscaling_policy_service/async_client.py
  58. +32 −44 google/cloud/dataproc_v1beta2/services/autoscaling_policy_service/client.py
  59. +1 −3 google/cloud/dataproc_v1beta2/services/autoscaling_policy_service/pagers.py
  60. +0 −2 google/cloud/dataproc_v1beta2/services/autoscaling_policy_service/transports/__init__.py
  61. +100 −37 google/cloud/dataproc_v1beta2/services/autoscaling_policy_service/transports/base.py
  62. +16 −14 google/cloud/dataproc_v1beta2/services/autoscaling_policy_service/transports/grpc.py
  63. +15 −15 google/cloud/dataproc_v1beta2/services/autoscaling_policy_service/transports/grpc_asyncio.py
  64. +0 −2 google/cloud/dataproc_v1beta2/services/cluster_controller/__init__.py
  65. +31 −43 google/cloud/dataproc_v1beta2/services/cluster_controller/async_client.py
  66. +37 −52 google/cloud/dataproc_v1beta2/services/cluster_controller/client.py
  67. +1 −3 google/cloud/dataproc_v1beta2/services/cluster_controller/pagers.py
  68. +0 −2 google/cloud/dataproc_v1beta2/services/cluster_controller/transports/__init__.py
  69. +110 −45 google/cloud/dataproc_v1beta2/services/cluster_controller/transports/base.py
  70. +20 −20 google/cloud/dataproc_v1beta2/services/cluster_controller/transports/grpc.py
  71. +22 −21 google/cloud/dataproc_v1beta2/services/cluster_controller/transports/grpc_asyncio.py
  72. +0 −2 google/cloud/dataproc_v1beta2/services/job_controller/__init__.py
  73. +29 −42 google/cloud/dataproc_v1beta2/services/job_controller/async_client.py
  74. +30 −47 google/cloud/dataproc_v1beta2/services/job_controller/client.py
  75. +1 −3 google/cloud/dataproc_v1beta2/services/job_controller/pagers.py
  76. +0 −2 google/cloud/dataproc_v1beta2/services/job_controller/transports/__init__.py
  77. +112 −53 google/cloud/dataproc_v1beta2/services/job_controller/transports/base.py
  78. +17 −17 google/cloud/dataproc_v1beta2/services/job_controller/transports/grpc.py
  79. +19 −18 google/cloud/dataproc_v1beta2/services/job_controller/transports/grpc_asyncio.py
  80. +0 −2 google/cloud/dataproc_v1beta2/services/workflow_template_service/__init__.py
  81. +34 −46 google/cloud/dataproc_v1beta2/services/workflow_template_service/async_client.py
  82. +39 −57 google/cloud/dataproc_v1beta2/services/workflow_template_service/client.py
  83. +1 −3 google/cloud/dataproc_v1beta2/services/workflow_template_service/pagers.py
  84. +0 −2 google/cloud/dataproc_v1beta2/services/workflow_template_service/transports/__init__.py
  85. +120 −50 google/cloud/dataproc_v1beta2/services/workflow_template_service/transports/base.py
  86. +20 −19 google/cloud/dataproc_v1beta2/services/workflow_template_service/transports/grpc.py
  87. +19 −20 google/cloud/dataproc_v1beta2/services/workflow_template_service/transports/grpc_asyncio.py
  88. +0 −2 google/cloud/dataproc_v1beta2/types/__init__.py
  89. +21 −43 google/cloud/dataproc_v1beta2/types/autoscaling_policies.py
  90. +100 −202 google/cloud/dataproc_v1beta2/types/clusters.py
  91. +92 −205 google/cloud/dataproc_v1beta2/types/jobs.py
  92. +10 −25 google/cloud/dataproc_v1beta2/types/operations.py
  93. +0 −2 google/cloud/dataproc_v1beta2/types/shared.py
  94. +59 −134 google/cloud/dataproc_v1beta2/types/workflow_templates.py
  95. +1 −1 noxfile.py
  96. +1 −0 owlbot.py
  97. +28 −29 scripts/fixup_dataproc_v1_keywords.py
  98. +26 −29 scripts/fixup_dataproc_v1beta2_keywords.py
  99. +1 −0 setup.py
  100. +2 −0 testing/constraints-3.6.txt
  101. +15 −0 tests/__init__.py
  102. +15 −0 tests/unit/__init__.py
  103. +15 −0 tests/unit/gapic/__init__.py
  104. +0 −1 tests/unit/gapic/dataproc_v1/__init__.py
  105. +305 −168 tests/unit/gapic/dataproc_v1/test_autoscaling_policy_service.py
  106. +509 −187 tests/unit/gapic/dataproc_v1/test_cluster_controller.py
  107. +317 −213 tests/unit/gapic/dataproc_v1/test_job_controller.py
  108. +375 −216 tests/unit/gapic/dataproc_v1/test_workflow_template_service.py
  109. +0 −1 tests/unit/gapic/dataproc_v1beta2/__init__.py
  110. +305 −168 tests/unit/gapic/dataproc_v1beta2/test_autoscaling_policy_service.py
  111. +301 −188 tests/unit/gapic/dataproc_v1beta2/test_cluster_controller.py
  112. +317 −221 tests/unit/gapic/dataproc_v1beta2/test_job_controller.py
  113. +327 −217 tests/unit/gapic/dataproc_v1beta2/test_workflow_template_service.py
Empty file.
@@ -5,7 +5,6 @@ AutoscalingPolicyService
:members:
:inherited-members:


.. automodule:: google.cloud.dataproc_v1.services.autoscaling_policy_service.pagers
:members:
:inherited-members:
@@ -5,7 +5,6 @@ ClusterController
:members:
:inherited-members:


.. automodule:: google.cloud.dataproc_v1.services.cluster_controller.pagers
:members:
:inherited-members:
@@ -5,7 +5,6 @@ JobController
:members:
:inherited-members:


.. automodule:: google.cloud.dataproc_v1.services.job_controller.pagers
:members:
:inherited-members:
@@ -5,7 +5,6 @@ WorkflowTemplateService
:members:
:inherited-members:


.. automodule:: google.cloud.dataproc_v1.services.workflow_template_service.pagers
:members:
:inherited-members:
@@ -5,7 +5,6 @@ AutoscalingPolicyService
:members:
:inherited-members:


.. automodule:: google.cloud.dataproc_v1beta2.services.autoscaling_policy_service.pagers
:members:
:inherited-members:
@@ -5,7 +5,6 @@ ClusterController
:members:
:inherited-members:


.. automodule:: google.cloud.dataproc_v1beta2.services.cluster_controller.pagers
:members:
:inherited-members:
@@ -5,7 +5,6 @@ JobController
:members:
:inherited-members:


.. automodule:: google.cloud.dataproc_v1beta2.services.job_controller.pagers
:members:
:inherited-members:
@@ -5,7 +5,6 @@ WorkflowTemplateService
:members:
:inherited-members:


.. automodule:: google.cloud.dataproc_v1beta2.services.workflow_template_service.pagers
:members:
:inherited-members:
@@ -1,5 +1,4 @@
# -*- coding: utf-8 -*-

# Copyright 2020 Google LLC
#
# Licensed under the Apache License, Version 2.0 (the "License");
@@ -15,28 +14,29 @@
# limitations under the License.
#

from google.cloud.dataproc_v1.services.autoscaling_policy_service.async_client import (
AutoscalingPolicyServiceAsyncClient,
)
from google.cloud.dataproc_v1.services.autoscaling_policy_service.client import (
AutoscalingPolicyServiceClient,
)
from google.cloud.dataproc_v1.services.cluster_controller.async_client import (
ClusterControllerAsyncClient,
from google.cloud.dataproc_v1.services.autoscaling_policy_service.async_client import (
AutoscalingPolicyServiceAsyncClient,
)
from google.cloud.dataproc_v1.services.cluster_controller.client import (
ClusterControllerClient,
)
from google.cloud.dataproc_v1.services.job_controller.async_client import (
JobControllerAsyncClient,
from google.cloud.dataproc_v1.services.cluster_controller.async_client import (
ClusterControllerAsyncClient,
)
from google.cloud.dataproc_v1.services.job_controller.client import JobControllerClient
from google.cloud.dataproc_v1.services.workflow_template_service.async_client import (
WorkflowTemplateServiceAsyncClient,
from google.cloud.dataproc_v1.services.job_controller.async_client import (
JobControllerAsyncClient,
)
from google.cloud.dataproc_v1.services.workflow_template_service.client import (
WorkflowTemplateServiceClient,
)
from google.cloud.dataproc_v1.services.workflow_template_service.async_client import (
WorkflowTemplateServiceAsyncClient,
)

from google.cloud.dataproc_v1.types.autoscaling_policies import AutoscalingPolicy
from google.cloud.dataproc_v1.types.autoscaling_policies import (
BasicAutoscalingAlgorithm,
@@ -80,16 +80,23 @@
from google.cloud.dataproc_v1.types.clusters import EndpointConfig
from google.cloud.dataproc_v1.types.clusters import GceClusterConfig
from google.cloud.dataproc_v1.types.clusters import GetClusterRequest
from google.cloud.dataproc_v1.types.clusters import GkeClusterConfig
from google.cloud.dataproc_v1.types.clusters import IdentityConfig
from google.cloud.dataproc_v1.types.clusters import InstanceGroupConfig
from google.cloud.dataproc_v1.types.clusters import KerberosConfig
from google.cloud.dataproc_v1.types.clusters import LifecycleConfig
from google.cloud.dataproc_v1.types.clusters import ListClustersRequest
from google.cloud.dataproc_v1.types.clusters import ListClustersResponse
from google.cloud.dataproc_v1.types.clusters import ManagedGroupConfig
from google.cloud.dataproc_v1.types.clusters import MetastoreConfig
from google.cloud.dataproc_v1.types.clusters import NodeGroupAffinity
from google.cloud.dataproc_v1.types.clusters import NodeInitializationAction
from google.cloud.dataproc_v1.types.clusters import ReservationAffinity
from google.cloud.dataproc_v1.types.clusters import SecurityConfig
from google.cloud.dataproc_v1.types.clusters import ShieldedInstanceConfig
from google.cloud.dataproc_v1.types.clusters import SoftwareConfig
from google.cloud.dataproc_v1.types.clusters import StartClusterRequest
from google.cloud.dataproc_v1.types.clusters import StopClusterRequest
from google.cloud.dataproc_v1.types.clusters import UpdateClusterRequest
from google.cloud.dataproc_v1.types.jobs import CancelJobRequest
from google.cloud.dataproc_v1.types.jobs import DeleteJobRequest
@@ -155,96 +162,103 @@
from google.cloud.dataproc_v1.types.workflow_templates import WorkflowTemplatePlacement

__all__ = (
"AcceleratorConfig",
"AutoscalingConfig",
"AutoscalingPolicy",
"AutoscalingPolicyServiceAsyncClient",
"AutoscalingPolicyServiceClient",
"AutoscalingPolicyServiceAsyncClient",
"ClusterControllerClient",
"ClusterControllerAsyncClient",
"JobControllerClient",
"JobControllerAsyncClient",
"WorkflowTemplateServiceClient",
"WorkflowTemplateServiceAsyncClient",
"AutoscalingPolicy",
"BasicAutoscalingAlgorithm",
"BasicYarnAutoscalingConfig",
"CancelJobRequest",
"CreateAutoscalingPolicyRequest",
"DeleteAutoscalingPolicyRequest",
"GetAutoscalingPolicyRequest",
"InstanceGroupAutoscalingPolicyConfig",
"ListAutoscalingPoliciesRequest",
"ListAutoscalingPoliciesResponse",
"UpdateAutoscalingPolicyRequest",
"AcceleratorConfig",
"AutoscalingConfig",
"Cluster",
"ClusterConfig",
"ClusterControllerAsyncClient",
"ClusterControllerClient",
"ClusterMetrics",
"ClusterOperation",
"ClusterOperationMetadata",
"ClusterOperationStatus",
"ClusterSelector",
"ClusterStatus",
"Component",
"CreateAutoscalingPolicyRequest",
"CreateClusterRequest",
"CreateWorkflowTemplateRequest",
"DeleteAutoscalingPolicyRequest",
"DeleteClusterRequest",
"DeleteJobRequest",
"DeleteWorkflowTemplateRequest",
"DiagnoseClusterRequest",
"DiagnoseClusterResults",
"DiskConfig",
"EncryptionConfig",
"EndpointConfig",
"GceClusterConfig",
"GetAutoscalingPolicyRequest",
"GetClusterRequest",
"GkeClusterConfig",
"IdentityConfig",
"InstanceGroupConfig",
"KerberosConfig",
"LifecycleConfig",
"ListClustersRequest",
"ListClustersResponse",
"ManagedGroupConfig",
"MetastoreConfig",
"NodeGroupAffinity",
"NodeInitializationAction",
"ReservationAffinity",
"SecurityConfig",
"ShieldedInstanceConfig",
"SoftwareConfig",
"StartClusterRequest",
"StopClusterRequest",
"UpdateClusterRequest",
"CancelJobRequest",
"DeleteJobRequest",
"GetJobRequest",
"GetWorkflowTemplateRequest",
"HadoopJob",
"HiveJob",
"InstanceGroupAutoscalingPolicyConfig",
"InstanceGroupConfig",
"InstantiateInlineWorkflowTemplateRequest",
"InstantiateWorkflowTemplateRequest",
"Job",
"JobControllerAsyncClient",
"JobControllerClient",
"JobMetadata",
"JobPlacement",
"JobReference",
"JobScheduling",
"JobStatus",
"KerberosConfig",
"LifecycleConfig",
"ListAutoscalingPoliciesRequest",
"ListAutoscalingPoliciesResponse",
"ListClustersRequest",
"ListClustersResponse",
"ListJobsRequest",
"ListJobsResponse",
"ListWorkflowTemplatesRequest",
"ListWorkflowTemplatesResponse",
"LoggingConfig",
"ManagedCluster",
"ManagedGroupConfig",
"NodeInitializationAction",
"OrderedJob",
"ParameterValidation",
"PigJob",
"PrestoJob",
"PySparkJob",
"QueryList",
"RegexValidation",
"ReservationAffinity",
"SecurityConfig",
"SoftwareConfig",
"SparkJob",
"SparkRJob",
"SparkSqlJob",
"SubmitJobRequest",
"TemplateParameter",
"UpdateAutoscalingPolicyRequest",
"UpdateClusterRequest",
"UpdateJobRequest",
"YarnApplication",
"ClusterOperationMetadata",
"ClusterOperationStatus",
"Component",
"ClusterOperation",
"ClusterSelector",
"CreateWorkflowTemplateRequest",
"DeleteWorkflowTemplateRequest",
"GetWorkflowTemplateRequest",
"InstantiateInlineWorkflowTemplateRequest",
"InstantiateWorkflowTemplateRequest",
"ListWorkflowTemplatesRequest",
"ListWorkflowTemplatesResponse",
"ManagedCluster",
"OrderedJob",
"ParameterValidation",
"RegexValidation",
"TemplateParameter",
"UpdateWorkflowTemplateRequest",
"ValueValidation",
"WorkflowGraph",
"WorkflowMetadata",
"WorkflowNode",
"WorkflowTemplate",
"WorkflowTemplatePlacement",
"WorkflowTemplateServiceAsyncClient",
"WorkflowTemplateServiceClient",
"YarnApplication",
)
@@ -1,5 +1,4 @@
# -*- coding: utf-8 -*-

# Copyright 2020 Google LLC
#
# Licensed under the Apache License, Version 2.0 (the "License");
@@ -16,9 +15,14 @@
#

from .services.autoscaling_policy_service import AutoscalingPolicyServiceClient
from .services.autoscaling_policy_service import AutoscalingPolicyServiceAsyncClient
from .services.cluster_controller import ClusterControllerClient
from .services.cluster_controller import ClusterControllerAsyncClient
from .services.job_controller import JobControllerClient
from .services.job_controller import JobControllerAsyncClient
from .services.workflow_template_service import WorkflowTemplateServiceClient
from .services.workflow_template_service import WorkflowTemplateServiceAsyncClient

from .types.autoscaling_policies import AutoscalingPolicy
from .types.autoscaling_policies import BasicAutoscalingAlgorithm
from .types.autoscaling_policies import BasicYarnAutoscalingConfig
@@ -44,16 +48,23 @@
from .types.clusters import EndpointConfig
from .types.clusters import GceClusterConfig
from .types.clusters import GetClusterRequest
from .types.clusters import GkeClusterConfig
from .types.clusters import IdentityConfig
from .types.clusters import InstanceGroupConfig
from .types.clusters import KerberosConfig
from .types.clusters import LifecycleConfig
from .types.clusters import ListClustersRequest
from .types.clusters import ListClustersResponse
from .types.clusters import ManagedGroupConfig
from .types.clusters import MetastoreConfig
from .types.clusters import NodeGroupAffinity
from .types.clusters import NodeInitializationAction
from .types.clusters import ReservationAffinity
from .types.clusters import SecurityConfig
from .types.clusters import ShieldedInstanceConfig
from .types.clusters import SoftwareConfig
from .types.clusters import StartClusterRequest
from .types.clusters import StopClusterRequest
from .types.clusters import UpdateClusterRequest
from .types.jobs import CancelJobRequest
from .types.jobs import DeleteJobRequest
@@ -104,8 +115,11 @@
from .types.workflow_templates import WorkflowTemplate
from .types.workflow_templates import WorkflowTemplatePlacement


__all__ = (
"AutoscalingPolicyServiceAsyncClient",
"ClusterControllerAsyncClient",
"JobControllerAsyncClient",
"WorkflowTemplateServiceAsyncClient",
"AcceleratorConfig",
"AutoscalingConfig",
"AutoscalingPolicy",
@@ -140,8 +154,10 @@
"GetClusterRequest",
"GetJobRequest",
"GetWorkflowTemplateRequest",
"GkeClusterConfig",
"HadoopJob",
"HiveJob",
"IdentityConfig",
"InstanceGroupAutoscalingPolicyConfig",
"InstanceGroupConfig",
"InstantiateInlineWorkflowTemplateRequest",
@@ -166,6 +182,8 @@
"LoggingConfig",
"ManagedCluster",
"ManagedGroupConfig",
"MetastoreConfig",
"NodeGroupAffinity",
"NodeInitializationAction",
"OrderedJob",
"ParameterValidation",
@@ -176,10 +194,13 @@
"RegexValidation",
"ReservationAffinity",
"SecurityConfig",
"ShieldedInstanceConfig",
"SoftwareConfig",
"SparkJob",
"SparkRJob",
"SparkSqlJob",
"StartClusterRequest",
"StopClusterRequest",
"SubmitJobRequest",
"TemplateParameter",
"UpdateAutoscalingPolicyRequest",
@@ -192,6 +213,6 @@
"WorkflowNode",
"WorkflowTemplate",
"WorkflowTemplatePlacement",
"YarnApplication",
"WorkflowTemplateServiceClient",
"YarnApplication",
)

0 comments on commit 5137a6f

Please sign in to comment.