dataproc.projects.locations.autoscalingPolicies.create

valid {
    input.Body.basicAlgorithm.cooldownPeriod == STRING
    input.Body.basicAlgorithm.sparkStandaloneConfig.gracefulDecommissionTimeout == STRING
    input.Body.basicAlgorithm.sparkStandaloneConfig.removeOnlyIdleWorkers == BOOLEAN
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleDownFactor == NUMBER
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleDownMinWorkerFraction == NUMBER
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleUpFactor == NUMBER
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleUpMinWorkerFraction == NUMBER
    input.Body.basicAlgorithm.yarnConfig.gracefulDecommissionTimeout == STRING
    input.Body.basicAlgorithm.yarnConfig.scaleDownFactor == NUMBER
    input.Body.basicAlgorithm.yarnConfig.scaleDownMinWorkerFraction == NUMBER
    input.Body.basicAlgorithm.yarnConfig.scaleUpFactor == NUMBER
    input.Body.basicAlgorithm.yarnConfig.scaleUpMinWorkerFraction == NUMBER
    input.Body.id == STRING
    input.Body.labels.STRING == STRING
    input.Body.secondaryWorkerConfig.maxInstances == INTEGER
    input.Body.secondaryWorkerConfig.minInstances == INTEGER
    input.Body.secondaryWorkerConfig.weight == INTEGER
    input.Body.workerConfig.maxInstances == INTEGER
    input.Body.workerConfig.minInstances == INTEGER
    input.Body.workerConfig.weight == INTEGER
    input.ReqMap.parent == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.autoscalingPolicies.delete

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.autoscalingPolicies.get

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.autoscalingPolicies.getIamPolicy

valid {
    input.Body.options.requestedPolicyVersion == INTEGER
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.autoscalingPolicies.list

valid {
    input.ReqMap.parent == STRING
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.autoscalingPolicies.setIamPolicy

valid {
    input.Body.policy.bindings[_].condition.description == STRING
    input.Body.policy.bindings[_].condition.expression == STRING
    input.Body.policy.bindings[_].condition.location == STRING
    input.Body.policy.bindings[_].condition.title == STRING
    input.Body.policy.bindings[_].members[_] == STRING
    input.Body.policy.bindings[_].role == STRING
    input.Body.policy.etag == STRING
    input.Body.policy.version == INTEGER
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.autoscalingPolicies.testIamPermissions

valid {
    input.Body.permissions[_] == STRING
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.autoscalingPolicies.update

valid {
    input.Body.basicAlgorithm.cooldownPeriod == STRING
    input.Body.basicAlgorithm.sparkStandaloneConfig.gracefulDecommissionTimeout == STRING
    input.Body.basicAlgorithm.sparkStandaloneConfig.removeOnlyIdleWorkers == BOOLEAN
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleDownFactor == NUMBER
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleDownMinWorkerFraction == NUMBER
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleUpFactor == NUMBER
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleUpMinWorkerFraction == NUMBER
    input.Body.basicAlgorithm.yarnConfig.gracefulDecommissionTimeout == STRING
    input.Body.basicAlgorithm.yarnConfig.scaleDownFactor == NUMBER
    input.Body.basicAlgorithm.yarnConfig.scaleDownMinWorkerFraction == NUMBER
    input.Body.basicAlgorithm.yarnConfig.scaleUpFactor == NUMBER
    input.Body.basicAlgorithm.yarnConfig.scaleUpMinWorkerFraction == NUMBER
    input.Body.id == STRING
    input.Body.labels.STRING == STRING
    input.Body.secondaryWorkerConfig.maxInstances == INTEGER
    input.Body.secondaryWorkerConfig.minInstances == INTEGER
    input.Body.secondaryWorkerConfig.weight == INTEGER
    input.Body.workerConfig.maxInstances == INTEGER
    input.Body.workerConfig.minInstances == INTEGER
    input.Body.workerConfig.weight == INTEGER
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.batches.analyze

valid {
    input.Body.requestId == STRING
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.batches.create

valid {
    input.Body.environmentConfig.executionConfig.idleTtl == STRING
    input.Body.environmentConfig.executionConfig.kmsKey == STRING
    input.Body.environmentConfig.executionConfig.networkTags[_] == STRING
    input.Body.environmentConfig.executionConfig.networkUri == STRING
    input.Body.environmentConfig.executionConfig.serviceAccount == STRING
    input.Body.environmentConfig.executionConfig.stagingBucket == STRING
    input.Body.environmentConfig.executionConfig.subnetworkUri == STRING
    input.Body.environmentConfig.executionConfig.ttl == STRING
    input.Body.environmentConfig.peripheralsConfig.metastoreService == STRING
    input.Body.environmentConfig.peripheralsConfig.sparkHistoryServerConfig.dataprocCluster == STRING
    input.Body.labels.STRING == STRING
    input.Body.pysparkBatch.archiveUris[_] == STRING
    input.Body.pysparkBatch.args[_] == STRING
    input.Body.pysparkBatch.fileUris[_] == STRING
    input.Body.pysparkBatch.jarFileUris[_] == STRING
    input.Body.pysparkBatch.mainPythonFileUri == STRING
    input.Body.pysparkBatch.pythonFileUris[_] == STRING
    input.Body.runtimeConfig.containerImage == STRING
    input.Body.runtimeConfig.properties.STRING == STRING
    input.Body.runtimeConfig.repositoryConfig.pypiRepositoryConfig.pypiRepository == STRING
    input.Body.runtimeConfig.version == STRING
    input.Body.sparkBatch.archiveUris[_] == STRING
    input.Body.sparkBatch.args[_] == STRING
    input.Body.sparkBatch.fileUris[_] == STRING
    input.Body.sparkBatch.jarFileUris[_] == STRING
    input.Body.sparkBatch.mainClass == STRING
    input.Body.sparkBatch.mainJarFileUri == STRING
    input.Body.sparkRBatch.archiveUris[_] == STRING
    input.Body.sparkRBatch.args[_] == STRING
    input.Body.sparkRBatch.fileUris[_] == STRING
    input.Body.sparkRBatch.mainRFileUri == STRING
    input.Body.sparkSqlBatch.jarFileUris[_] == STRING
    input.Body.sparkSqlBatch.queryFileUri == STRING
    input.Body.sparkSqlBatch.queryVariables.STRING == STRING
    input.ReqMap.parent == STRING
    input.Qs.batchId == STRING
    input.Qs.requestId == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.batches.delete

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.batches.get

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.batches.list

valid {
    input.ReqMap.parent == STRING
    input.Qs.filter == STRING
    input.Qs.orderBy == STRING
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.operations.cancel

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.operations.delete

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.operations.get

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.operations.list

valid {
    input.ReqMap.name == STRING
    input.Qs.filter == STRING
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.sessionTemplates.create

enum_JupyterConfigKernel := [ "KERNEL_UNSPECIFIED", "PYTHON", "SCALA" ]

valid {
    input.Body.description == STRING
    input.Body.environmentConfig.executionConfig.idleTtl == STRING
    input.Body.environmentConfig.executionConfig.kmsKey == STRING
    input.Body.environmentConfig.executionConfig.networkTags[_] == STRING
    input.Body.environmentConfig.executionConfig.networkUri == STRING
    input.Body.environmentConfig.executionConfig.serviceAccount == STRING
    input.Body.environmentConfig.executionConfig.stagingBucket == STRING
    input.Body.environmentConfig.executionConfig.subnetworkUri == STRING
    input.Body.environmentConfig.executionConfig.ttl == STRING
    input.Body.environmentConfig.peripheralsConfig.metastoreService == STRING
    input.Body.environmentConfig.peripheralsConfig.sparkHistoryServerConfig.dataprocCluster == STRING
    input.Body.jupyterSession.displayName == STRING
    input.Body.jupyterSession.kernel == enum_JupyterConfigKernel[_]
    input.Body.labels.STRING == STRING
    input.Body.name == STRING
    input.Body.runtimeConfig.containerImage == STRING
    input.Body.runtimeConfig.properties.STRING == STRING
    input.Body.runtimeConfig.repositoryConfig.pypiRepositoryConfig.pypiRepository == STRING
    input.Body.runtimeConfig.version == STRING
    input.ReqMap.parent == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.sessionTemplates.delete

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.sessionTemplates.get

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.sessionTemplates.list

valid {
    input.ReqMap.parent == STRING
    input.Qs.filter == STRING
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.sessionTemplates.patch

enum_JupyterConfigKernel := [ "KERNEL_UNSPECIFIED", "PYTHON", "SCALA" ]

valid {
    input.Body.description == STRING
    input.Body.environmentConfig.executionConfig.idleTtl == STRING
    input.Body.environmentConfig.executionConfig.kmsKey == STRING
    input.Body.environmentConfig.executionConfig.networkTags[_] == STRING
    input.Body.environmentConfig.executionConfig.networkUri == STRING
    input.Body.environmentConfig.executionConfig.serviceAccount == STRING
    input.Body.environmentConfig.executionConfig.stagingBucket == STRING
    input.Body.environmentConfig.executionConfig.subnetworkUri == STRING
    input.Body.environmentConfig.executionConfig.ttl == STRING
    input.Body.environmentConfig.peripheralsConfig.metastoreService == STRING
    input.Body.environmentConfig.peripheralsConfig.sparkHistoryServerConfig.dataprocCluster == STRING
    input.Body.jupyterSession.displayName == STRING
    input.Body.jupyterSession.kernel == enum_JupyterConfigKernel[_]
    input.Body.labels.STRING == STRING
    input.Body.name == STRING
    input.Body.runtimeConfig.containerImage == STRING
    input.Body.runtimeConfig.properties.STRING == STRING
    input.Body.runtimeConfig.repositoryConfig.pypiRepositoryConfig.pypiRepository == STRING
    input.Body.runtimeConfig.version == STRING
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.sessions.create

enum_JupyterConfigKernel := [ "KERNEL_UNSPECIFIED", "PYTHON", "SCALA" ]

valid {
    input.Body.environmentConfig.executionConfig.idleTtl == STRING
    input.Body.environmentConfig.executionConfig.kmsKey == STRING
    input.Body.environmentConfig.executionConfig.networkTags[_] == STRING
    input.Body.environmentConfig.executionConfig.networkUri == STRING
    input.Body.environmentConfig.executionConfig.serviceAccount == STRING
    input.Body.environmentConfig.executionConfig.stagingBucket == STRING
    input.Body.environmentConfig.executionConfig.subnetworkUri == STRING
    input.Body.environmentConfig.executionConfig.ttl == STRING
    input.Body.environmentConfig.peripheralsConfig.metastoreService == STRING
    input.Body.environmentConfig.peripheralsConfig.sparkHistoryServerConfig.dataprocCluster == STRING
    input.Body.jupyterSession.displayName == STRING
    input.Body.jupyterSession.kernel == enum_JupyterConfigKernel[_]
    input.Body.labels.STRING == STRING
    input.Body.name == STRING
    input.Body.runtimeConfig.containerImage == STRING
    input.Body.runtimeConfig.properties.STRING == STRING
    input.Body.runtimeConfig.repositoryConfig.pypiRepositoryConfig.pypiRepository == STRING
    input.Body.runtimeConfig.version == STRING
    input.Body.sessionTemplate == STRING
    input.Body.user == STRING
    input.ReqMap.parent == STRING
    input.Qs.requestId == STRING
    input.Qs.sessionId == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.sessions.delete

valid {
    input.ReqMap.name == STRING
    input.Qs.requestId == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.sessions.get

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.sessions.list

valid {
    input.ReqMap.parent == STRING
    input.Qs.filter == STRING
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.sessions.terminate

valid {
    input.Body.requestId == STRING
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.workflowTemplates.create

enum_GceClusterConfigPrivateIpv6GoogleAccess := [ "PRIVATE_IPV6_GOOGLE_ACCESS_UNSPECIFIED", "INHERIT_FROM_SUBNETWORK", "OUTBOUND", "BIDIRECTIONAL" ]
enum_GkeNodePoolTargetRoles := [ "ROLE_UNSPECIFIED", "DEFAULT", "CONTROLLER", "SPARK_DRIVER", "SPARK_EXECUTOR" ]
enum_InstanceGroupConfigPreemptibility := [ "PREEMPTIBILITY_UNSPECIFIED", "NON_PREEMPTIBLE", "PREEMPTIBLE", "SPOT" ]
enum_LoggingConfigDriverLogLevels := [ "LEVEL_UNSPECIFIED", "ALL", "TRACE", "DEBUG", "INFO", "WARN", "ERROR", "FATAL", "OFF" ]
enum_MetricMetricSource := [ "METRIC_SOURCE_UNSPECIFIED", "MONITORING_AGENT_DEFAULTS", "HDFS", "SPARK", "YARN", "SPARK_HISTORY_SERVER", "HIVESERVER2", "HIVEMETASTORE", "FLINK" ]
enum_NodeGroupRoles := [ "ROLE_UNSPECIFIED", "DRIVER" ]
enum_ReservationAffinityConsumeReservationType := [ "TYPE_UNSPECIFIED", "NO_RESERVATION", "ANY_RESERVATION", "SPECIFIC_RESERVATION" ]
enum_SoftwareConfigOptionalComponents := [ "COMPONENT_UNSPECIFIED", "ANACONDA", "DOCKER", "DRUID", "FLINK", "HBASE", "HIVE_WEBHCAT", "HUDI", "JUPYTER", "PRESTO", "TRINO", "RANGER", "SOLR", "ZEPPELIN", "ZOOKEEPER" ]

valid {
    input.Body.dagTimeout == STRING
    input.Body.encryptionConfig.kmsKey == STRING
    input.Body.id == STRING
    input.Body.jobs[_].flinkJob.args[_] == STRING
    input.Body.jobs[_].flinkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].flinkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].flinkJob.mainClass == STRING
    input.Body.jobs[_].flinkJob.mainJarFileUri == STRING
    input.Body.jobs[_].flinkJob.properties.STRING == STRING
    input.Body.jobs[_].flinkJob.savepointUri == STRING
    input.Body.jobs[_].hadoopJob.archiveUris[_] == STRING
    input.Body.jobs[_].hadoopJob.args[_] == STRING
    input.Body.jobs[_].hadoopJob.fileUris[_] == STRING
    input.Body.jobs[_].hadoopJob.jarFileUris[_] == STRING
    input.Body.jobs[_].hadoopJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].hadoopJob.mainClass == STRING
    input.Body.jobs[_].hadoopJob.mainJarFileUri == STRING
    input.Body.jobs[_].hadoopJob.properties.STRING == STRING
    input.Body.jobs[_].hiveJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].hiveJob.jarFileUris[_] == STRING
    input.Body.jobs[_].hiveJob.properties.STRING == STRING
    input.Body.jobs[_].hiveJob.queryFileUri == STRING
    input.Body.jobs[_].hiveJob.queryList.queries[_] == STRING
    input.Body.jobs[_].hiveJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].labels.STRING == STRING
    input.Body.jobs[_].pigJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].pigJob.jarFileUris[_] == STRING
    input.Body.jobs[_].pigJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].pigJob.properties.STRING == STRING
    input.Body.jobs[_].pigJob.queryFileUri == STRING
    input.Body.jobs[_].pigJob.queryList.queries[_] == STRING
    input.Body.jobs[_].pigJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].prerequisiteStepIds[_] == STRING
    input.Body.jobs[_].prestoJob.clientTags[_] == STRING
    input.Body.jobs[_].prestoJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].prestoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].prestoJob.outputFormat == STRING
    input.Body.jobs[_].prestoJob.properties.STRING == STRING
    input.Body.jobs[_].prestoJob.queryFileUri == STRING
    input.Body.jobs[_].prestoJob.queryList.queries[_] == STRING
    input.Body.jobs[_].pysparkJob.archiveUris[_] == STRING
    input.Body.jobs[_].pysparkJob.args[_] == STRING
    input.Body.jobs[_].pysparkJob.fileUris[_] == STRING
    input.Body.jobs[_].pysparkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].pysparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].pysparkJob.mainPythonFileUri == STRING
    input.Body.jobs[_].pysparkJob.properties.STRING == STRING
    input.Body.jobs[_].pysparkJob.pythonFileUris[_] == STRING
    input.Body.jobs[_].scheduling.maxFailuresPerHour == INTEGER
    input.Body.jobs[_].scheduling.maxFailuresTotal == INTEGER
    input.Body.jobs[_].sparkJob.archiveUris[_] == STRING
    input.Body.jobs[_].sparkJob.args[_] == STRING
    input.Body.jobs[_].sparkJob.fileUris[_] == STRING
    input.Body.jobs[_].sparkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].sparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkJob.mainClass == STRING
    input.Body.jobs[_].sparkJob.mainJarFileUri == STRING
    input.Body.jobs[_].sparkJob.properties.STRING == STRING
    input.Body.jobs[_].sparkRJob.archiveUris[_] == STRING
    input.Body.jobs[_].sparkRJob.args[_] == STRING
    input.Body.jobs[_].sparkRJob.fileUris[_] == STRING
    input.Body.jobs[_].sparkRJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkRJob.mainRFileUri == STRING
    input.Body.jobs[_].sparkRJob.properties.STRING == STRING
    input.Body.jobs[_].sparkSqlJob.jarFileUris[_] == STRING
    input.Body.jobs[_].sparkSqlJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkSqlJob.properties.STRING == STRING
    input.Body.jobs[_].sparkSqlJob.queryFileUri == STRING
    input.Body.jobs[_].sparkSqlJob.queryList.queries[_] == STRING
    input.Body.jobs[_].sparkSqlJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].stepId == STRING
    input.Body.jobs[_].trinoJob.clientTags[_] == STRING
    input.Body.jobs[_].trinoJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].trinoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].trinoJob.outputFormat == STRING
    input.Body.jobs[_].trinoJob.properties.STRING == STRING
    input.Body.jobs[_].trinoJob.queryFileUri == STRING
    input.Body.jobs[_].trinoJob.queryList.queries[_] == STRING
    input.Body.labels.STRING == STRING
    input.Body.parameters[_].description == STRING
    input.Body.parameters[_].fields[_] == STRING
    input.Body.parameters[_].name == STRING
    input.Body.parameters[_].validation.regex.regexes[_] == STRING
    input.Body.parameters[_].validation.values.values[_] == STRING
    input.Body.placement.clusterSelector.clusterLabels.STRING == STRING
    input.Body.placement.clusterSelector.zone == STRING
    input.Body.placement.managedCluster.clusterName == STRING
    input.Body.placement.managedCluster.config.autoscalingConfig.policyUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.labels.STRING == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.name == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.roles[_] == enum_NodeGroupRoles[_]
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroupId == STRING
    input.Body.placement.managedCluster.config.configBucket == STRING
    input.Body.placement.managedCluster.config.dataprocMetricConfig.metrics[_].metricOverrides[_] == STRING
    input.Body.placement.managedCluster.config.dataprocMetricConfig.metrics[_].metricSource == enum_MetricMetricSource[_]
    input.Body.placement.managedCluster.config.encryptionConfig.gcePdKmsKeyName == STRING
    input.Body.placement.managedCluster.config.encryptionConfig.kmsKey == STRING
    input.Body.placement.managedCluster.config.endpointConfig.enableHttpPortAccess == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.confidentialInstanceConfig.enableConfidentialCompute == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.internalIpOnly == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.metadata.STRING == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.networkUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.nodeGroupAffinity.nodeGroupUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.privateIpv6GoogleAccess == enum_GceClusterConfigPrivateIpv6GoogleAccess[_]
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.consumeReservationType == enum_ReservationAffinityConsumeReservationType[_]
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.key == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.values[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.serviceAccount == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.serviceAccountScopes[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableIntegrityMonitoring == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableSecureBoot == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableVtpm == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.subnetworkUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.tags[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.zoneUri == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.gkeClusterTarget == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.namespacedGkeDeploymentTarget.clusterNamespace == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.namespacedGkeDeploymentTarget.targetGkeCluster == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePool == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.maxNodeCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.minNodeCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorCount == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorType == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].gpuPartitionSize == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.bootDiskKmsKey == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.localSsdCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.machineType == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.preemptible == BOOLEAN
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.spot == BOOLEAN
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.locations[_] == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].roles[_] == enum_GkeNodePoolTargetRoles[_]
    input.Body.placement.managedCluster.config.initializationActions[_].executableFile == STRING
    input.Body.placement.managedCluster.config.initializationActions[_].executionTimeout == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.autoDeleteTime == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.autoDeleteTtl == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.idleDeleteTtl == STRING
    input.Body.placement.managedCluster.config.masterConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.masterConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.masterConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.metastoreConfig.dataprocMetastoreService == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.securityConfig.identityConfig.userServiceAccountMapping.STRING == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustAdminServer == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustKdc == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustRealm == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustSharedPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.enableKerberos == BOOLEAN
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.kdcDbKeyUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keyPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keystorePasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keystoreUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.kmsKeyUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.realm == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.rootPrincipalPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.tgtLifetimeHours == INTEGER
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.truststorePasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.truststoreUri == STRING
    input.Body.placement.managedCluster.config.softwareConfig.imageVersion == STRING
    input.Body.placement.managedCluster.config.softwareConfig.optionalComponents[_] == enum_SoftwareConfigOptionalComponents[_]
    input.Body.placement.managedCluster.config.softwareConfig.properties.STRING == STRING
    input.Body.placement.managedCluster.config.tempBucket == STRING
    input.Body.placement.managedCluster.config.workerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.workerConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.workerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.labels.STRING == STRING
    input.Body.version == INTEGER
    input.ReqMap.parent == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.workflowTemplates.delete

valid {
    input.ReqMap.name == STRING
    input.Qs.version == INTEGER
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.workflowTemplates.get

valid {
    input.ReqMap.name == STRING
    input.Qs.version == INTEGER
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.workflowTemplates.getIamPolicy

valid {
    input.Body.options.requestedPolicyVersion == INTEGER
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.workflowTemplates.instantiate

valid {
    input.Body.parameters.STRING == STRING
    input.Body.requestId == STRING
    input.Body.version == INTEGER
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.workflowTemplates.instantiateInline

enum_GceClusterConfigPrivateIpv6GoogleAccess := [ "PRIVATE_IPV6_GOOGLE_ACCESS_UNSPECIFIED", "INHERIT_FROM_SUBNETWORK", "OUTBOUND", "BIDIRECTIONAL" ]
enum_GkeNodePoolTargetRoles := [ "ROLE_UNSPECIFIED", "DEFAULT", "CONTROLLER", "SPARK_DRIVER", "SPARK_EXECUTOR" ]
enum_InstanceGroupConfigPreemptibility := [ "PREEMPTIBILITY_UNSPECIFIED", "NON_PREEMPTIBLE", "PREEMPTIBLE", "SPOT" ]
enum_LoggingConfigDriverLogLevels := [ "LEVEL_UNSPECIFIED", "ALL", "TRACE", "DEBUG", "INFO", "WARN", "ERROR", "FATAL", "OFF" ]
enum_MetricMetricSource := [ "METRIC_SOURCE_UNSPECIFIED", "MONITORING_AGENT_DEFAULTS", "HDFS", "SPARK", "YARN", "SPARK_HISTORY_SERVER", "HIVESERVER2", "HIVEMETASTORE", "FLINK" ]
enum_NodeGroupRoles := [ "ROLE_UNSPECIFIED", "DRIVER" ]
enum_ReservationAffinityConsumeReservationType := [ "TYPE_UNSPECIFIED", "NO_RESERVATION", "ANY_RESERVATION", "SPECIFIC_RESERVATION" ]
enum_SoftwareConfigOptionalComponents := [ "COMPONENT_UNSPECIFIED", "ANACONDA", "DOCKER", "DRUID", "FLINK", "HBASE", "HIVE_WEBHCAT", "HUDI", "JUPYTER", "PRESTO", "TRINO", "RANGER", "SOLR", "ZEPPELIN", "ZOOKEEPER" ]

valid {
    input.Body.dagTimeout == STRING
    input.Body.encryptionConfig.kmsKey == STRING
    input.Body.id == STRING
    input.Body.jobs[_].flinkJob.args[_] == STRING
    input.Body.jobs[_].flinkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].flinkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].flinkJob.mainClass == STRING
    input.Body.jobs[_].flinkJob.mainJarFileUri == STRING
    input.Body.jobs[_].flinkJob.properties.STRING == STRING
    input.Body.jobs[_].flinkJob.savepointUri == STRING
    input.Body.jobs[_].hadoopJob.archiveUris[_] == STRING
    input.Body.jobs[_].hadoopJob.args[_] == STRING
    input.Body.jobs[_].hadoopJob.fileUris[_] == STRING
    input.Body.jobs[_].hadoopJob.jarFileUris[_] == STRING
    input.Body.jobs[_].hadoopJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].hadoopJob.mainClass == STRING
    input.Body.jobs[_].hadoopJob.mainJarFileUri == STRING
    input.Body.jobs[_].hadoopJob.properties.STRING == STRING
    input.Body.jobs[_].hiveJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].hiveJob.jarFileUris[_] == STRING
    input.Body.jobs[_].hiveJob.properties.STRING == STRING
    input.Body.jobs[_].hiveJob.queryFileUri == STRING
    input.Body.jobs[_].hiveJob.queryList.queries[_] == STRING
    input.Body.jobs[_].hiveJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].labels.STRING == STRING
    input.Body.jobs[_].pigJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].pigJob.jarFileUris[_] == STRING
    input.Body.jobs[_].pigJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].pigJob.properties.STRING == STRING
    input.Body.jobs[_].pigJob.queryFileUri == STRING
    input.Body.jobs[_].pigJob.queryList.queries[_] == STRING
    input.Body.jobs[_].pigJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].prerequisiteStepIds[_] == STRING
    input.Body.jobs[_].prestoJob.clientTags[_] == STRING
    input.Body.jobs[_].prestoJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].prestoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].prestoJob.outputFormat == STRING
    input.Body.jobs[_].prestoJob.properties.STRING == STRING
    input.Body.jobs[_].prestoJob.queryFileUri == STRING
    input.Body.jobs[_].prestoJob.queryList.queries[_] == STRING
    input.Body.jobs[_].pysparkJob.archiveUris[_] == STRING
    input.Body.jobs[_].pysparkJob.args[_] == STRING
    input.Body.jobs[_].pysparkJob.fileUris[_] == STRING
    input.Body.jobs[_].pysparkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].pysparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].pysparkJob.mainPythonFileUri == STRING
    input.Body.jobs[_].pysparkJob.properties.STRING == STRING
    input.Body.jobs[_].pysparkJob.pythonFileUris[_] == STRING
    input.Body.jobs[_].scheduling.maxFailuresPerHour == INTEGER
    input.Body.jobs[_].scheduling.maxFailuresTotal == INTEGER
    input.Body.jobs[_].sparkJob.archiveUris[_] == STRING
    input.Body.jobs[_].sparkJob.args[_] == STRING
    input.Body.jobs[_].sparkJob.fileUris[_] == STRING
    input.Body.jobs[_].sparkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].sparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkJob.mainClass == STRING
    input.Body.jobs[_].sparkJob.mainJarFileUri == STRING
    input.Body.jobs[_].sparkJob.properties.STRING == STRING
    input.Body.jobs[_].sparkRJob.archiveUris[_] == STRING
    input.Body.jobs[_].sparkRJob.args[_] == STRING
    input.Body.jobs[_].sparkRJob.fileUris[_] == STRING
    input.Body.jobs[_].sparkRJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkRJob.mainRFileUri == STRING
    input.Body.jobs[_].sparkRJob.properties.STRING == STRING
    input.Body.jobs[_].sparkSqlJob.jarFileUris[_] == STRING
    input.Body.jobs[_].sparkSqlJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkSqlJob.properties.STRING == STRING
    input.Body.jobs[_].sparkSqlJob.queryFileUri == STRING
    input.Body.jobs[_].sparkSqlJob.queryList.queries[_] == STRING
    input.Body.jobs[_].sparkSqlJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].stepId == STRING
    input.Body.jobs[_].trinoJob.clientTags[_] == STRING
    input.Body.jobs[_].trinoJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].trinoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].trinoJob.outputFormat == STRING
    input.Body.jobs[_].trinoJob.properties.STRING == STRING
    input.Body.jobs[_].trinoJob.queryFileUri == STRING
    input.Body.jobs[_].trinoJob.queryList.queries[_] == STRING
    input.Body.labels.STRING == STRING
    input.Body.parameters[_].description == STRING
    input.Body.parameters[_].fields[_] == STRING
    input.Body.parameters[_].name == STRING
    input.Body.parameters[_].validation.regex.regexes[_] == STRING
    input.Body.parameters[_].validation.values.values[_] == STRING
    input.Body.placement.clusterSelector.clusterLabels.STRING == STRING
    input.Body.placement.clusterSelector.zone == STRING
    input.Body.placement.managedCluster.clusterName == STRING
    input.Body.placement.managedCluster.config.autoscalingConfig.policyUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.labels.STRING == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.name == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.roles[_] == enum_NodeGroupRoles[_]
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroupId == STRING
    input.Body.placement.managedCluster.config.configBucket == STRING
    input.Body.placement.managedCluster.config.dataprocMetricConfig.metrics[_].metricOverrides[_] == STRING
    input.Body.placement.managedCluster.config.dataprocMetricConfig.metrics[_].metricSource == enum_MetricMetricSource[_]
    input.Body.placement.managedCluster.config.encryptionConfig.gcePdKmsKeyName == STRING
    input.Body.placement.managedCluster.config.encryptionConfig.kmsKey == STRING
    input.Body.placement.managedCluster.config.endpointConfig.enableHttpPortAccess == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.confidentialInstanceConfig.enableConfidentialCompute == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.internalIpOnly == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.metadata.STRING == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.networkUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.nodeGroupAffinity.nodeGroupUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.privateIpv6GoogleAccess == enum_GceClusterConfigPrivateIpv6GoogleAccess[_]
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.consumeReservationType == enum_ReservationAffinityConsumeReservationType[_]
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.key == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.values[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.serviceAccount == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.serviceAccountScopes[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableIntegrityMonitoring == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableSecureBoot == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableVtpm == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.subnetworkUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.tags[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.zoneUri == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.gkeClusterTarget == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.namespacedGkeDeploymentTarget.clusterNamespace == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.namespacedGkeDeploymentTarget.targetGkeCluster == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePool == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.maxNodeCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.minNodeCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorCount == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorType == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].gpuPartitionSize == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.bootDiskKmsKey == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.localSsdCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.machineType == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.preemptible == BOOLEAN
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.spot == BOOLEAN
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.locations[_] == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].roles[_] == enum_GkeNodePoolTargetRoles[_]
    input.Body.placement.managedCluster.config.initializationActions[_].executableFile == STRING
    input.Body.placement.managedCluster.config.initializationActions[_].executionTimeout == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.autoDeleteTime == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.autoDeleteTtl == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.idleDeleteTtl == STRING
    input.Body.placement.managedCluster.config.masterConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.masterConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.masterConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.metastoreConfig.dataprocMetastoreService == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.securityConfig.identityConfig.userServiceAccountMapping.STRING == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustAdminServer == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustKdc == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustRealm == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustSharedPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.enableKerberos == BOOLEAN
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.kdcDbKeyUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keyPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keystorePasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keystoreUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.kmsKeyUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.realm == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.rootPrincipalPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.tgtLifetimeHours == INTEGER
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.truststorePasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.truststoreUri == STRING
    input.Body.placement.managedCluster.config.softwareConfig.imageVersion == STRING
    input.Body.placement.managedCluster.config.softwareConfig.optionalComponents[_] == enum_SoftwareConfigOptionalComponents[_]
    input.Body.placement.managedCluster.config.softwareConfig.properties.STRING == STRING
    input.Body.placement.managedCluster.config.tempBucket == STRING
    input.Body.placement.managedCluster.config.workerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.workerConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.workerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.labels.STRING == STRING
    input.Body.version == INTEGER
    input.ReqMap.parent == STRING
    input.Qs.requestId == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.workflowTemplates.list

valid {
    input.ReqMap.parent == STRING
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.workflowTemplates.setIamPolicy

valid {
    input.Body.policy.bindings[_].condition.description == STRING
    input.Body.policy.bindings[_].condition.expression == STRING
    input.Body.policy.bindings[_].condition.location == STRING
    input.Body.policy.bindings[_].condition.title == STRING
    input.Body.policy.bindings[_].members[_] == STRING
    input.Body.policy.bindings[_].role == STRING
    input.Body.policy.etag == STRING
    input.Body.policy.version == INTEGER
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.workflowTemplates.testIamPermissions

valid {
    input.Body.permissions[_] == STRING
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.locations.workflowTemplates.update

enum_GceClusterConfigPrivateIpv6GoogleAccess := [ "PRIVATE_IPV6_GOOGLE_ACCESS_UNSPECIFIED", "INHERIT_FROM_SUBNETWORK", "OUTBOUND", "BIDIRECTIONAL" ]
enum_GkeNodePoolTargetRoles := [ "ROLE_UNSPECIFIED", "DEFAULT", "CONTROLLER", "SPARK_DRIVER", "SPARK_EXECUTOR" ]
enum_InstanceGroupConfigPreemptibility := [ "PREEMPTIBILITY_UNSPECIFIED", "NON_PREEMPTIBLE", "PREEMPTIBLE", "SPOT" ]
enum_LoggingConfigDriverLogLevels := [ "LEVEL_UNSPECIFIED", "ALL", "TRACE", "DEBUG", "INFO", "WARN", "ERROR", "FATAL", "OFF" ]
enum_MetricMetricSource := [ "METRIC_SOURCE_UNSPECIFIED", "MONITORING_AGENT_DEFAULTS", "HDFS", "SPARK", "YARN", "SPARK_HISTORY_SERVER", "HIVESERVER2", "HIVEMETASTORE", "FLINK" ]
enum_NodeGroupRoles := [ "ROLE_UNSPECIFIED", "DRIVER" ]
enum_ReservationAffinityConsumeReservationType := [ "TYPE_UNSPECIFIED", "NO_RESERVATION", "ANY_RESERVATION", "SPECIFIC_RESERVATION" ]
enum_SoftwareConfigOptionalComponents := [ "COMPONENT_UNSPECIFIED", "ANACONDA", "DOCKER", "DRUID", "FLINK", "HBASE", "HIVE_WEBHCAT", "HUDI", "JUPYTER", "PRESTO", "TRINO", "RANGER", "SOLR", "ZEPPELIN", "ZOOKEEPER" ]

valid {
    input.Body.dagTimeout == STRING
    input.Body.encryptionConfig.kmsKey == STRING
    input.Body.id == STRING
    input.Body.jobs[_].flinkJob.args[_] == STRING
    input.Body.jobs[_].flinkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].flinkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].flinkJob.mainClass == STRING
    input.Body.jobs[_].flinkJob.mainJarFileUri == STRING
    input.Body.jobs[_].flinkJob.properties.STRING == STRING
    input.Body.jobs[_].flinkJob.savepointUri == STRING
    input.Body.jobs[_].hadoopJob.archiveUris[_] == STRING
    input.Body.jobs[_].hadoopJob.args[_] == STRING
    input.Body.jobs[_].hadoopJob.fileUris[_] == STRING
    input.Body.jobs[_].hadoopJob.jarFileUris[_] == STRING
    input.Body.jobs[_].hadoopJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].hadoopJob.mainClass == STRING
    input.Body.jobs[_].hadoopJob.mainJarFileUri == STRING
    input.Body.jobs[_].hadoopJob.properties.STRING == STRING
    input.Body.jobs[_].hiveJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].hiveJob.jarFileUris[_] == STRING
    input.Body.jobs[_].hiveJob.properties.STRING == STRING
    input.Body.jobs[_].hiveJob.queryFileUri == STRING
    input.Body.jobs[_].hiveJob.queryList.queries[_] == STRING
    input.Body.jobs[_].hiveJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].labels.STRING == STRING
    input.Body.jobs[_].pigJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].pigJob.jarFileUris[_] == STRING
    input.Body.jobs[_].pigJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].pigJob.properties.STRING == STRING
    input.Body.jobs[_].pigJob.queryFileUri == STRING
    input.Body.jobs[_].pigJob.queryList.queries[_] == STRING
    input.Body.jobs[_].pigJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].prerequisiteStepIds[_] == STRING
    input.Body.jobs[_].prestoJob.clientTags[_] == STRING
    input.Body.jobs[_].prestoJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].prestoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].prestoJob.outputFormat == STRING
    input.Body.jobs[_].prestoJob.properties.STRING == STRING
    input.Body.jobs[_].prestoJob.queryFileUri == STRING
    input.Body.jobs[_].prestoJob.queryList.queries[_] == STRING
    input.Body.jobs[_].pysparkJob.archiveUris[_] == STRING
    input.Body.jobs[_].pysparkJob.args[_] == STRING
    input.Body.jobs[_].pysparkJob.fileUris[_] == STRING
    input.Body.jobs[_].pysparkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].pysparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].pysparkJob.mainPythonFileUri == STRING
    input.Body.jobs[_].pysparkJob.properties.STRING == STRING
    input.Body.jobs[_].pysparkJob.pythonFileUris[_] == STRING
    input.Body.jobs[_].scheduling.maxFailuresPerHour == INTEGER
    input.Body.jobs[_].scheduling.maxFailuresTotal == INTEGER
    input.Body.jobs[_].sparkJob.archiveUris[_] == STRING
    input.Body.jobs[_].sparkJob.args[_] == STRING
    input.Body.jobs[_].sparkJob.fileUris[_] == STRING
    input.Body.jobs[_].sparkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].sparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkJob.mainClass == STRING
    input.Body.jobs[_].sparkJob.mainJarFileUri == STRING
    input.Body.jobs[_].sparkJob.properties.STRING == STRING
    input.Body.jobs[_].sparkRJob.archiveUris[_] == STRING
    input.Body.jobs[_].sparkRJob.args[_] == STRING
    input.Body.jobs[_].sparkRJob.fileUris[_] == STRING
    input.Body.jobs[_].sparkRJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkRJob.mainRFileUri == STRING
    input.Body.jobs[_].sparkRJob.properties.STRING == STRING
    input.Body.jobs[_].sparkSqlJob.jarFileUris[_] == STRING
    input.Body.jobs[_].sparkSqlJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkSqlJob.properties.STRING == STRING
    input.Body.jobs[_].sparkSqlJob.queryFileUri == STRING
    input.Body.jobs[_].sparkSqlJob.queryList.queries[_] == STRING
    input.Body.jobs[_].sparkSqlJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].stepId == STRING
    input.Body.jobs[_].trinoJob.clientTags[_] == STRING
    input.Body.jobs[_].trinoJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].trinoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].trinoJob.outputFormat == STRING
    input.Body.jobs[_].trinoJob.properties.STRING == STRING
    input.Body.jobs[_].trinoJob.queryFileUri == STRING
    input.Body.jobs[_].trinoJob.queryList.queries[_] == STRING
    input.Body.labels.STRING == STRING
    input.Body.parameters[_].description == STRING
    input.Body.parameters[_].fields[_] == STRING
    input.Body.parameters[_].name == STRING
    input.Body.parameters[_].validation.regex.regexes[_] == STRING
    input.Body.parameters[_].validation.values.values[_] == STRING
    input.Body.placement.clusterSelector.clusterLabels.STRING == STRING
    input.Body.placement.clusterSelector.zone == STRING
    input.Body.placement.managedCluster.clusterName == STRING
    input.Body.placement.managedCluster.config.autoscalingConfig.policyUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.labels.STRING == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.name == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.roles[_] == enum_NodeGroupRoles[_]
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroupId == STRING
    input.Body.placement.managedCluster.config.configBucket == STRING
    input.Body.placement.managedCluster.config.dataprocMetricConfig.metrics[_].metricOverrides[_] == STRING
    input.Body.placement.managedCluster.config.dataprocMetricConfig.metrics[_].metricSource == enum_MetricMetricSource[_]
    input.Body.placement.managedCluster.config.encryptionConfig.gcePdKmsKeyName == STRING
    input.Body.placement.managedCluster.config.encryptionConfig.kmsKey == STRING
    input.Body.placement.managedCluster.config.endpointConfig.enableHttpPortAccess == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.confidentialInstanceConfig.enableConfidentialCompute == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.internalIpOnly == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.metadata.STRING == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.networkUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.nodeGroupAffinity.nodeGroupUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.privateIpv6GoogleAccess == enum_GceClusterConfigPrivateIpv6GoogleAccess[_]
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.consumeReservationType == enum_ReservationAffinityConsumeReservationType[_]
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.key == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.values[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.serviceAccount == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.serviceAccountScopes[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableIntegrityMonitoring == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableSecureBoot == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableVtpm == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.subnetworkUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.tags[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.zoneUri == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.gkeClusterTarget == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.namespacedGkeDeploymentTarget.clusterNamespace == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.namespacedGkeDeploymentTarget.targetGkeCluster == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePool == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.maxNodeCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.minNodeCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorCount == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorType == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].gpuPartitionSize == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.bootDiskKmsKey == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.localSsdCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.machineType == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.preemptible == BOOLEAN
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.spot == BOOLEAN
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.locations[_] == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].roles[_] == enum_GkeNodePoolTargetRoles[_]
    input.Body.placement.managedCluster.config.initializationActions[_].executableFile == STRING
    input.Body.placement.managedCluster.config.initializationActions[_].executionTimeout == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.autoDeleteTime == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.autoDeleteTtl == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.idleDeleteTtl == STRING
    input.Body.placement.managedCluster.config.masterConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.masterConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.masterConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.metastoreConfig.dataprocMetastoreService == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.securityConfig.identityConfig.userServiceAccountMapping.STRING == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustAdminServer == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustKdc == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustRealm == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustSharedPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.enableKerberos == BOOLEAN
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.kdcDbKeyUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keyPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keystorePasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keystoreUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.kmsKeyUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.realm == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.rootPrincipalPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.tgtLifetimeHours == INTEGER
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.truststorePasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.truststoreUri == STRING
    input.Body.placement.managedCluster.config.softwareConfig.imageVersion == STRING
    input.Body.placement.managedCluster.config.softwareConfig.optionalComponents[_] == enum_SoftwareConfigOptionalComponents[_]
    input.Body.placement.managedCluster.config.softwareConfig.properties.STRING == STRING
    input.Body.placement.managedCluster.config.tempBucket == STRING
    input.Body.placement.managedCluster.config.workerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.workerConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.workerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.labels.STRING == STRING
    input.Body.version == INTEGER
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.autoscalingPolicies.create

valid {
    input.Body.basicAlgorithm.cooldownPeriod == STRING
    input.Body.basicAlgorithm.sparkStandaloneConfig.gracefulDecommissionTimeout == STRING
    input.Body.basicAlgorithm.sparkStandaloneConfig.removeOnlyIdleWorkers == BOOLEAN
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleDownFactor == NUMBER
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleDownMinWorkerFraction == NUMBER
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleUpFactor == NUMBER
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleUpMinWorkerFraction == NUMBER
    input.Body.basicAlgorithm.yarnConfig.gracefulDecommissionTimeout == STRING
    input.Body.basicAlgorithm.yarnConfig.scaleDownFactor == NUMBER
    input.Body.basicAlgorithm.yarnConfig.scaleDownMinWorkerFraction == NUMBER
    input.Body.basicAlgorithm.yarnConfig.scaleUpFactor == NUMBER
    input.Body.basicAlgorithm.yarnConfig.scaleUpMinWorkerFraction == NUMBER
    input.Body.id == STRING
    input.Body.labels.STRING == STRING
    input.Body.secondaryWorkerConfig.maxInstances == INTEGER
    input.Body.secondaryWorkerConfig.minInstances == INTEGER
    input.Body.secondaryWorkerConfig.weight == INTEGER
    input.Body.workerConfig.maxInstances == INTEGER
    input.Body.workerConfig.minInstances == INTEGER
    input.Body.workerConfig.weight == INTEGER
    input.ReqMap.parent == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.autoscalingPolicies.delete

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.autoscalingPolicies.get

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.autoscalingPolicies.getIamPolicy

valid {
    input.Body.options.requestedPolicyVersion == INTEGER
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.autoscalingPolicies.list

valid {
    input.ReqMap.parent == STRING
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.autoscalingPolicies.setIamPolicy

valid {
    input.Body.policy.bindings[_].condition.description == STRING
    input.Body.policy.bindings[_].condition.expression == STRING
    input.Body.policy.bindings[_].condition.location == STRING
    input.Body.policy.bindings[_].condition.title == STRING
    input.Body.policy.bindings[_].members[_] == STRING
    input.Body.policy.bindings[_].role == STRING
    input.Body.policy.etag == STRING
    input.Body.policy.version == INTEGER
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.autoscalingPolicies.testIamPermissions

valid {
    input.Body.permissions[_] == STRING
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.autoscalingPolicies.update

valid {
    input.Body.basicAlgorithm.cooldownPeriod == STRING
    input.Body.basicAlgorithm.sparkStandaloneConfig.gracefulDecommissionTimeout == STRING
    input.Body.basicAlgorithm.sparkStandaloneConfig.removeOnlyIdleWorkers == BOOLEAN
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleDownFactor == NUMBER
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleDownMinWorkerFraction == NUMBER
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleUpFactor == NUMBER
    input.Body.basicAlgorithm.sparkStandaloneConfig.scaleUpMinWorkerFraction == NUMBER
    input.Body.basicAlgorithm.yarnConfig.gracefulDecommissionTimeout == STRING
    input.Body.basicAlgorithm.yarnConfig.scaleDownFactor == NUMBER
    input.Body.basicAlgorithm.yarnConfig.scaleDownMinWorkerFraction == NUMBER
    input.Body.basicAlgorithm.yarnConfig.scaleUpFactor == NUMBER
    input.Body.basicAlgorithm.yarnConfig.scaleUpMinWorkerFraction == NUMBER
    input.Body.id == STRING
    input.Body.labels.STRING == STRING
    input.Body.secondaryWorkerConfig.maxInstances == INTEGER
    input.Body.secondaryWorkerConfig.minInstances == INTEGER
    input.Body.secondaryWorkerConfig.weight == INTEGER
    input.Body.workerConfig.maxInstances == INTEGER
    input.Body.workerConfig.minInstances == INTEGER
    input.Body.workerConfig.weight == INTEGER
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.clusters.create

enum_ActionOnFailedPrimaryWorkersParameter := [ "FAILURE_ACTION_UNSPECIFIED", "NO_ACTION", "DELETE" ]
enum_GceClusterConfigPrivateIpv6GoogleAccess := [ "PRIVATE_IPV6_GOOGLE_ACCESS_UNSPECIFIED", "INHERIT_FROM_SUBNETWORK", "OUTBOUND", "BIDIRECTIONAL" ]
enum_GkeNodePoolTargetRoles := [ "ROLE_UNSPECIFIED", "DEFAULT", "CONTROLLER", "SPARK_DRIVER", "SPARK_EXECUTOR" ]
enum_InstanceGroupConfigPreemptibility := [ "PREEMPTIBILITY_UNSPECIFIED", "NON_PREEMPTIBLE", "PREEMPTIBLE", "SPOT" ]
enum_MetricMetricSource := [ "METRIC_SOURCE_UNSPECIFIED", "MONITORING_AGENT_DEFAULTS", "HDFS", "SPARK", "YARN", "SPARK_HISTORY_SERVER", "HIVESERVER2", "HIVEMETASTORE", "FLINK" ]
enum_NodeGroupRoles := [ "ROLE_UNSPECIFIED", "DRIVER" ]
enum_ReservationAffinityConsumeReservationType := [ "TYPE_UNSPECIFIED", "NO_RESERVATION", "ANY_RESERVATION", "SPECIFIC_RESERVATION" ]
enum_SoftwareConfigOptionalComponents := [ "COMPONENT_UNSPECIFIED", "ANACONDA", "DOCKER", "DRUID", "FLINK", "HBASE", "HIVE_WEBHCAT", "HUDI", "JUPYTER", "PRESTO", "TRINO", "RANGER", "SOLR", "ZEPPELIN", "ZOOKEEPER" ]

valid {
    input.Body.clusterName == STRING
    input.Body.config.autoscalingConfig.policyUri == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.labels.STRING == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.name == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskType == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.localSsdInterface == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.imageUri == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.machineTypeUri == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minCpuPlatform == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minNumInstances == INTEGER
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.numInstances == INTEGER
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.roles[_] == enum_NodeGroupRoles[_]
    input.Body.config.auxiliaryNodeGroups[_].nodeGroupId == STRING
    input.Body.config.configBucket == STRING
    input.Body.config.dataprocMetricConfig.metrics[_].metricOverrides[_] == STRING
    input.Body.config.dataprocMetricConfig.metrics[_].metricSource == enum_MetricMetricSource[_]
    input.Body.config.encryptionConfig.gcePdKmsKeyName == STRING
    input.Body.config.encryptionConfig.kmsKey == STRING
    input.Body.config.endpointConfig.enableHttpPortAccess == BOOLEAN
    input.Body.config.gceClusterConfig.confidentialInstanceConfig.enableConfidentialCompute == BOOLEAN
    input.Body.config.gceClusterConfig.internalIpOnly == BOOLEAN
    input.Body.config.gceClusterConfig.metadata.STRING == STRING
    input.Body.config.gceClusterConfig.networkUri == STRING
    input.Body.config.gceClusterConfig.nodeGroupAffinity.nodeGroupUri == STRING
    input.Body.config.gceClusterConfig.privateIpv6GoogleAccess == enum_GceClusterConfigPrivateIpv6GoogleAccess[_]
    input.Body.config.gceClusterConfig.reservationAffinity.consumeReservationType == enum_ReservationAffinityConsumeReservationType[_]
    input.Body.config.gceClusterConfig.reservationAffinity.key == STRING
    input.Body.config.gceClusterConfig.reservationAffinity.values[_] == STRING
    input.Body.config.gceClusterConfig.serviceAccount == STRING
    input.Body.config.gceClusterConfig.serviceAccountScopes[_] == STRING
    input.Body.config.gceClusterConfig.shieldedInstanceConfig.enableIntegrityMonitoring == BOOLEAN
    input.Body.config.gceClusterConfig.shieldedInstanceConfig.enableSecureBoot == BOOLEAN
    input.Body.config.gceClusterConfig.shieldedInstanceConfig.enableVtpm == BOOLEAN
    input.Body.config.gceClusterConfig.subnetworkUri == STRING
    input.Body.config.gceClusterConfig.tags[_] == STRING
    input.Body.config.gceClusterConfig.zoneUri == STRING
    input.Body.config.gkeClusterConfig.gkeClusterTarget == STRING
    input.Body.config.gkeClusterConfig.namespacedGkeDeploymentTarget.clusterNamespace == STRING
    input.Body.config.gkeClusterConfig.namespacedGkeDeploymentTarget.targetGkeCluster == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePool == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.maxNodeCount == INTEGER
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.minNodeCount == INTEGER
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorCount == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorType == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].gpuPartitionSize == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.bootDiskKmsKey == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.localSsdCount == INTEGER
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.machineType == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.minCpuPlatform == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.preemptible == BOOLEAN
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.spot == BOOLEAN
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.locations[_] == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].roles[_] == enum_GkeNodePoolTargetRoles[_]
    input.Body.config.initializationActions[_].executableFile == STRING
    input.Body.config.initializationActions[_].executionTimeout == STRING
    input.Body.config.lifecycleConfig.autoDeleteTime == STRING
    input.Body.config.lifecycleConfig.autoDeleteTtl == STRING
    input.Body.config.lifecycleConfig.idleDeleteTtl == STRING
    input.Body.config.masterConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.config.masterConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.config.masterConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.config.masterConfig.diskConfig.bootDiskType == STRING
    input.Body.config.masterConfig.diskConfig.localSsdInterface == STRING
    input.Body.config.masterConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.config.masterConfig.imageUri == STRING
    input.Body.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.config.masterConfig.machineTypeUri == STRING
    input.Body.config.masterConfig.minCpuPlatform == STRING
    input.Body.config.masterConfig.minNumInstances == INTEGER
    input.Body.config.masterConfig.numInstances == INTEGER
    input.Body.config.masterConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.config.masterConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.config.metastoreConfig.dataprocMetastoreService == STRING
    input.Body.config.secondaryWorkerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.config.secondaryWorkerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.config.secondaryWorkerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.config.secondaryWorkerConfig.diskConfig.bootDiskType == STRING
    input.Body.config.secondaryWorkerConfig.diskConfig.localSsdInterface == STRING
    input.Body.config.secondaryWorkerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.config.secondaryWorkerConfig.imageUri == STRING
    input.Body.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.config.secondaryWorkerConfig.machineTypeUri == STRING
    input.Body.config.secondaryWorkerConfig.minCpuPlatform == STRING
    input.Body.config.secondaryWorkerConfig.minNumInstances == INTEGER
    input.Body.config.secondaryWorkerConfig.numInstances == INTEGER
    input.Body.config.secondaryWorkerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.config.secondaryWorkerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.config.securityConfig.identityConfig.userServiceAccountMapping.STRING == STRING
    input.Body.config.securityConfig.kerberosConfig.crossRealmTrustAdminServer == STRING
    input.Body.config.securityConfig.kerberosConfig.crossRealmTrustKdc == STRING
    input.Body.config.securityConfig.kerberosConfig.crossRealmTrustRealm == STRING
    input.Body.config.securityConfig.kerberosConfig.crossRealmTrustSharedPasswordUri == STRING
    input.Body.config.securityConfig.kerberosConfig.enableKerberos == BOOLEAN
    input.Body.config.securityConfig.kerberosConfig.kdcDbKeyUri == STRING
    input.Body.config.securityConfig.kerberosConfig.keyPasswordUri == STRING
    input.Body.config.securityConfig.kerberosConfig.keystorePasswordUri == STRING
    input.Body.config.securityConfig.kerberosConfig.keystoreUri == STRING
    input.Body.config.securityConfig.kerberosConfig.kmsKeyUri == STRING
    input.Body.config.securityConfig.kerberosConfig.realm == STRING
    input.Body.config.securityConfig.kerberosConfig.rootPrincipalPasswordUri == STRING
    input.Body.config.securityConfig.kerberosConfig.tgtLifetimeHours == INTEGER
    input.Body.config.securityConfig.kerberosConfig.truststorePasswordUri == STRING
    input.Body.config.securityConfig.kerberosConfig.truststoreUri == STRING
    input.Body.config.softwareConfig.imageVersion == STRING
    input.Body.config.softwareConfig.optionalComponents[_] == enum_SoftwareConfigOptionalComponents[_]
    input.Body.config.softwareConfig.properties.STRING == STRING
    input.Body.config.tempBucket == STRING
    input.Body.config.workerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.config.workerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.config.workerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.config.workerConfig.diskConfig.bootDiskType == STRING
    input.Body.config.workerConfig.diskConfig.localSsdInterface == STRING
    input.Body.config.workerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.config.workerConfig.imageUri == STRING
    input.Body.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.config.workerConfig.machineTypeUri == STRING
    input.Body.config.workerConfig.minCpuPlatform == STRING
    input.Body.config.workerConfig.minNumInstances == INTEGER
    input.Body.config.workerConfig.numInstances == INTEGER
    input.Body.config.workerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.config.workerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.labels.STRING == STRING
    input.Body.projectId == STRING
    input.Body.virtualClusterConfig.auxiliaryServicesConfig.metastoreConfig.dataprocMetastoreService == STRING
    input.Body.virtualClusterConfig.auxiliaryServicesConfig.sparkHistoryServerConfig.dataprocCluster == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.gkeClusterTarget == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.namespacedGkeDeploymentTarget.clusterNamespace == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.namespacedGkeDeploymentTarget.targetGkeCluster == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePool == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.maxNodeCount == INTEGER
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.minNodeCount == INTEGER
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorCount == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorType == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].gpuPartitionSize == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.bootDiskKmsKey == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.localSsdCount == INTEGER
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.machineType == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.minCpuPlatform == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.preemptible == BOOLEAN
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.spot == BOOLEAN
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.locations[_] == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].roles[_] == enum_GkeNodePoolTargetRoles[_]
    input.Body.virtualClusterConfig.kubernetesClusterConfig.kubernetesNamespace == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.kubernetesSoftwareConfig.componentVersion.STRING == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.kubernetesSoftwareConfig.properties.STRING == STRING
    input.Body.virtualClusterConfig.stagingBucket == STRING
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.Qs.actionOnFailedPrimaryWorkers == enum_ActionOnFailedPrimaryWorkersParameter[_]
    input.Qs.requestId == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.clusters.delete

valid {
    input.ReqMap.clusterName == STRING
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.Qs.clusterUuid == STRING
    input.Qs.gracefulTerminationTimeout == STRING
    input.Qs.requestId == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.clusters.diagnose

enum_DiagnoseClusterRequestTarballAccess := [ "TARBALL_ACCESS_UNSPECIFIED", "GOOGLE_CLOUD_SUPPORT", "GOOGLE_DATAPROC_DIAGNOSE" ]

valid {
    input.Body.diagnosisInterval.endTime == STRING
    input.Body.diagnosisInterval.startTime == STRING
    input.Body.job == STRING
    input.Body.jobs[_] == STRING
    input.Body.tarballAccess == enum_DiagnoseClusterRequestTarballAccess[_]
    input.Body.tarballGcsDir == STRING
    input.Body.yarnApplicationId == STRING
    input.Body.yarnApplicationIds[_] == STRING
    input.ReqMap.clusterName == STRING
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.clusters.get

valid {
    input.ReqMap.clusterName == STRING
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.clusters.getIamPolicy

valid {
    input.Body.options.requestedPolicyVersion == INTEGER
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.clusters.injectCredentials

valid {
    input.Body.clusterUuid == STRING
    input.Body.credentialsCiphertext == STRING
    input.ReqMap.cluster == STRING
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.clusters.list

valid {
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.Qs.filter == STRING
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.clusters.nodeGroups.create

enum_InstanceGroupConfigPreemptibility := [ "PREEMPTIBILITY_UNSPECIFIED", "NON_PREEMPTIBLE", "PREEMPTIBLE", "SPOT" ]
enum_NodeGroupRoles := [ "ROLE_UNSPECIFIED", "DRIVER" ]

valid {
    input.Body.labels.STRING == STRING
    input.Body.name == STRING
    input.Body.nodeGroupConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.nodeGroupConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.nodeGroupConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.nodeGroupConfig.diskConfig.bootDiskType == STRING
    input.Body.nodeGroupConfig.diskConfig.localSsdInterface == STRING
    input.Body.nodeGroupConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.nodeGroupConfig.imageUri == STRING
    input.Body.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.nodeGroupConfig.machineTypeUri == STRING
    input.Body.nodeGroupConfig.minCpuPlatform == STRING
    input.Body.nodeGroupConfig.minNumInstances == INTEGER
    input.Body.nodeGroupConfig.numInstances == INTEGER
    input.Body.nodeGroupConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.nodeGroupConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.roles[_] == enum_NodeGroupRoles[_]
    input.ReqMap.parent == STRING
    input.Qs.nodeGroupId == STRING
    input.Qs.parentOperationId == STRING
    input.Qs.requestId == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.clusters.nodeGroups.get

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.clusters.nodeGroups.repair

enum_RepairNodeGroupRequestRepairAction := [ "REPAIR_ACTION_UNSPECIFIED", "REPLACE" ]

valid {
    input.Body.instanceNames[_] == STRING
    input.Body.repairAction == enum_RepairNodeGroupRequestRepairAction[_]
    input.Body.requestId == STRING
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.clusters.nodeGroups.resize

valid {
    input.Body.gracefulDecommissionTimeout == STRING
    input.Body.parentOperationId == STRING
    input.Body.requestId == STRING
    input.Body.size == INTEGER
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.clusters.patch

enum_GceClusterConfigPrivateIpv6GoogleAccess := [ "PRIVATE_IPV6_GOOGLE_ACCESS_UNSPECIFIED", "INHERIT_FROM_SUBNETWORK", "OUTBOUND", "BIDIRECTIONAL" ]
enum_GkeNodePoolTargetRoles := [ "ROLE_UNSPECIFIED", "DEFAULT", "CONTROLLER", "SPARK_DRIVER", "SPARK_EXECUTOR" ]
enum_InstanceGroupConfigPreemptibility := [ "PREEMPTIBILITY_UNSPECIFIED", "NON_PREEMPTIBLE", "PREEMPTIBLE", "SPOT" ]
enum_MetricMetricSource := [ "METRIC_SOURCE_UNSPECIFIED", "MONITORING_AGENT_DEFAULTS", "HDFS", "SPARK", "YARN", "SPARK_HISTORY_SERVER", "HIVESERVER2", "HIVEMETASTORE", "FLINK" ]
enum_NodeGroupRoles := [ "ROLE_UNSPECIFIED", "DRIVER" ]
enum_ReservationAffinityConsumeReservationType := [ "TYPE_UNSPECIFIED", "NO_RESERVATION", "ANY_RESERVATION", "SPECIFIC_RESERVATION" ]
enum_SoftwareConfigOptionalComponents := [ "COMPONENT_UNSPECIFIED", "ANACONDA", "DOCKER", "DRUID", "FLINK", "HBASE", "HIVE_WEBHCAT", "HUDI", "JUPYTER", "PRESTO", "TRINO", "RANGER", "SOLR", "ZEPPELIN", "ZOOKEEPER" ]

valid {
    input.Body.clusterName == STRING
    input.Body.config.autoscalingConfig.policyUri == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.labels.STRING == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.name == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskType == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.localSsdInterface == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.imageUri == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.machineTypeUri == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minCpuPlatform == STRING
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minNumInstances == INTEGER
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.numInstances == INTEGER
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.config.auxiliaryNodeGroups[_].nodeGroup.roles[_] == enum_NodeGroupRoles[_]
    input.Body.config.auxiliaryNodeGroups[_].nodeGroupId == STRING
    input.Body.config.configBucket == STRING
    input.Body.config.dataprocMetricConfig.metrics[_].metricOverrides[_] == STRING
    input.Body.config.dataprocMetricConfig.metrics[_].metricSource == enum_MetricMetricSource[_]
    input.Body.config.encryptionConfig.gcePdKmsKeyName == STRING
    input.Body.config.encryptionConfig.kmsKey == STRING
    input.Body.config.endpointConfig.enableHttpPortAccess == BOOLEAN
    input.Body.config.gceClusterConfig.confidentialInstanceConfig.enableConfidentialCompute == BOOLEAN
    input.Body.config.gceClusterConfig.internalIpOnly == BOOLEAN
    input.Body.config.gceClusterConfig.metadata.STRING == STRING
    input.Body.config.gceClusterConfig.networkUri == STRING
    input.Body.config.gceClusterConfig.nodeGroupAffinity.nodeGroupUri == STRING
    input.Body.config.gceClusterConfig.privateIpv6GoogleAccess == enum_GceClusterConfigPrivateIpv6GoogleAccess[_]
    input.Body.config.gceClusterConfig.reservationAffinity.consumeReservationType == enum_ReservationAffinityConsumeReservationType[_]
    input.Body.config.gceClusterConfig.reservationAffinity.key == STRING
    input.Body.config.gceClusterConfig.reservationAffinity.values[_] == STRING
    input.Body.config.gceClusterConfig.serviceAccount == STRING
    input.Body.config.gceClusterConfig.serviceAccountScopes[_] == STRING
    input.Body.config.gceClusterConfig.shieldedInstanceConfig.enableIntegrityMonitoring == BOOLEAN
    input.Body.config.gceClusterConfig.shieldedInstanceConfig.enableSecureBoot == BOOLEAN
    input.Body.config.gceClusterConfig.shieldedInstanceConfig.enableVtpm == BOOLEAN
    input.Body.config.gceClusterConfig.subnetworkUri == STRING
    input.Body.config.gceClusterConfig.tags[_] == STRING
    input.Body.config.gceClusterConfig.zoneUri == STRING
    input.Body.config.gkeClusterConfig.gkeClusterTarget == STRING
    input.Body.config.gkeClusterConfig.namespacedGkeDeploymentTarget.clusterNamespace == STRING
    input.Body.config.gkeClusterConfig.namespacedGkeDeploymentTarget.targetGkeCluster == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePool == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.maxNodeCount == INTEGER
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.minNodeCount == INTEGER
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorCount == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorType == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].gpuPartitionSize == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.bootDiskKmsKey == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.localSsdCount == INTEGER
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.machineType == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.minCpuPlatform == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.preemptible == BOOLEAN
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.spot == BOOLEAN
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.locations[_] == STRING
    input.Body.config.gkeClusterConfig.nodePoolTarget[_].roles[_] == enum_GkeNodePoolTargetRoles[_]
    input.Body.config.initializationActions[_].executableFile == STRING
    input.Body.config.initializationActions[_].executionTimeout == STRING
    input.Body.config.lifecycleConfig.autoDeleteTime == STRING
    input.Body.config.lifecycleConfig.autoDeleteTtl == STRING
    input.Body.config.lifecycleConfig.idleDeleteTtl == STRING
    input.Body.config.masterConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.config.masterConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.config.masterConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.config.masterConfig.diskConfig.bootDiskType == STRING
    input.Body.config.masterConfig.diskConfig.localSsdInterface == STRING
    input.Body.config.masterConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.config.masterConfig.imageUri == STRING
    input.Body.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.config.masterConfig.machineTypeUri == STRING
    input.Body.config.masterConfig.minCpuPlatform == STRING
    input.Body.config.masterConfig.minNumInstances == INTEGER
    input.Body.config.masterConfig.numInstances == INTEGER
    input.Body.config.masterConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.config.masterConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.config.metastoreConfig.dataprocMetastoreService == STRING
    input.Body.config.secondaryWorkerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.config.secondaryWorkerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.config.secondaryWorkerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.config.secondaryWorkerConfig.diskConfig.bootDiskType == STRING
    input.Body.config.secondaryWorkerConfig.diskConfig.localSsdInterface == STRING
    input.Body.config.secondaryWorkerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.config.secondaryWorkerConfig.imageUri == STRING
    input.Body.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.config.secondaryWorkerConfig.machineTypeUri == STRING
    input.Body.config.secondaryWorkerConfig.minCpuPlatform == STRING
    input.Body.config.secondaryWorkerConfig.minNumInstances == INTEGER
    input.Body.config.secondaryWorkerConfig.numInstances == INTEGER
    input.Body.config.secondaryWorkerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.config.secondaryWorkerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.config.securityConfig.identityConfig.userServiceAccountMapping.STRING == STRING
    input.Body.config.securityConfig.kerberosConfig.crossRealmTrustAdminServer == STRING
    input.Body.config.securityConfig.kerberosConfig.crossRealmTrustKdc == STRING
    input.Body.config.securityConfig.kerberosConfig.crossRealmTrustRealm == STRING
    input.Body.config.securityConfig.kerberosConfig.crossRealmTrustSharedPasswordUri == STRING
    input.Body.config.securityConfig.kerberosConfig.enableKerberos == BOOLEAN
    input.Body.config.securityConfig.kerberosConfig.kdcDbKeyUri == STRING
    input.Body.config.securityConfig.kerberosConfig.keyPasswordUri == STRING
    input.Body.config.securityConfig.kerberosConfig.keystorePasswordUri == STRING
    input.Body.config.securityConfig.kerberosConfig.keystoreUri == STRING
    input.Body.config.securityConfig.kerberosConfig.kmsKeyUri == STRING
    input.Body.config.securityConfig.kerberosConfig.realm == STRING
    input.Body.config.securityConfig.kerberosConfig.rootPrincipalPasswordUri == STRING
    input.Body.config.securityConfig.kerberosConfig.tgtLifetimeHours == INTEGER
    input.Body.config.securityConfig.kerberosConfig.truststorePasswordUri == STRING
    input.Body.config.securityConfig.kerberosConfig.truststoreUri == STRING
    input.Body.config.softwareConfig.imageVersion == STRING
    input.Body.config.softwareConfig.optionalComponents[_] == enum_SoftwareConfigOptionalComponents[_]
    input.Body.config.softwareConfig.properties.STRING == STRING
    input.Body.config.tempBucket == STRING
    input.Body.config.workerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.config.workerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.config.workerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.config.workerConfig.diskConfig.bootDiskType == STRING
    input.Body.config.workerConfig.diskConfig.localSsdInterface == STRING
    input.Body.config.workerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.config.workerConfig.imageUri == STRING
    input.Body.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.config.workerConfig.machineTypeUri == STRING
    input.Body.config.workerConfig.minCpuPlatform == STRING
    input.Body.config.workerConfig.minNumInstances == INTEGER
    input.Body.config.workerConfig.numInstances == INTEGER
    input.Body.config.workerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.config.workerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.labels.STRING == STRING
    input.Body.projectId == STRING
    input.Body.virtualClusterConfig.auxiliaryServicesConfig.metastoreConfig.dataprocMetastoreService == STRING
    input.Body.virtualClusterConfig.auxiliaryServicesConfig.sparkHistoryServerConfig.dataprocCluster == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.gkeClusterTarget == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.namespacedGkeDeploymentTarget.clusterNamespace == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.namespacedGkeDeploymentTarget.targetGkeCluster == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePool == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.maxNodeCount == INTEGER
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.minNodeCount == INTEGER
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorCount == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorType == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].gpuPartitionSize == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.bootDiskKmsKey == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.localSsdCount == INTEGER
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.machineType == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.minCpuPlatform == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.preemptible == BOOLEAN
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.spot == BOOLEAN
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.locations[_] == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.gkeClusterConfig.nodePoolTarget[_].roles[_] == enum_GkeNodePoolTargetRoles[_]
    input.Body.virtualClusterConfig.kubernetesClusterConfig.kubernetesNamespace == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.kubernetesSoftwareConfig.componentVersion.STRING == STRING
    input.Body.virtualClusterConfig.kubernetesClusterConfig.kubernetesSoftwareConfig.properties.STRING == STRING
    input.Body.virtualClusterConfig.stagingBucket == STRING
    input.ReqMap.clusterName == STRING
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.Qs.gracefulDecommissionTimeout == STRING
    input.Qs.requestId == STRING
    input.Qs.updateMask == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.clusters.repair

enum_NodePoolRepairAction := [ "REPAIR_ACTION_UNSPECIFIED", "DELETE" ]

valid {
    input.Body.clusterUuid == STRING
    input.Body.gracefulDecommissionTimeout == STRING
    input.Body.nodePools[_].id == STRING
    input.Body.nodePools[_].instanceNames[_] == STRING
    input.Body.nodePools[_].repairAction == enum_NodePoolRepairAction[_]
    input.Body.parentOperationId == STRING
    input.Body.requestId == STRING
    input.ReqMap.clusterName == STRING
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.clusters.setIamPolicy

valid {
    input.Body.policy.bindings[_].condition.description == STRING
    input.Body.policy.bindings[_].condition.expression == STRING
    input.Body.policy.bindings[_].condition.location == STRING
    input.Body.policy.bindings[_].condition.title == STRING
    input.Body.policy.bindings[_].members[_] == STRING
    input.Body.policy.bindings[_].role == STRING
    input.Body.policy.etag == STRING
    input.Body.policy.version == INTEGER
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.clusters.start

valid {
    input.Body.clusterUuid == STRING
    input.Body.requestId == STRING
    input.ReqMap.clusterName == STRING
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.clusters.stop

valid {
    input.Body.clusterUuid == STRING
    input.Body.requestId == STRING
    input.ReqMap.clusterName == STRING
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.clusters.testIamPermissions

valid {
    input.Body.permissions[_] == STRING
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.jobs.cancel

valid {
    input.Body.STRING == STRING
    input.ReqMap.jobId == STRING
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.jobs.delete

valid {
    input.ReqMap.jobId == STRING
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.jobs.get

valid {
    input.ReqMap.jobId == STRING
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.jobs.getIamPolicy

valid {
    input.Body.options.requestedPolicyVersion == INTEGER
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.jobs.list

enum_JobStateMatcherParameter := [ "ALL", "ACTIVE", "NON_ACTIVE" ]

valid {
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.Qs.clusterName == STRING
    input.Qs.filter == STRING
    input.Qs.jobStateMatcher == enum_JobStateMatcherParameter[_]
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.jobs.patch

enum_LoggingConfigDriverLogLevels := [ "LEVEL_UNSPECIFIED", "ALL", "TRACE", "DEBUG", "INFO", "WARN", "ERROR", "FATAL", "OFF" ]

valid {
    input.Body.driverSchedulingConfig.memoryMb == INTEGER
    input.Body.driverSchedulingConfig.vcores == INTEGER
    input.Body.flinkJob.args[_] == STRING
    input.Body.flinkJob.jarFileUris[_] == STRING
    input.Body.flinkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.flinkJob.mainClass == STRING
    input.Body.flinkJob.mainJarFileUri == STRING
    input.Body.flinkJob.properties.STRING == STRING
    input.Body.flinkJob.savepointUri == STRING
    input.Body.hadoopJob.archiveUris[_] == STRING
    input.Body.hadoopJob.args[_] == STRING
    input.Body.hadoopJob.fileUris[_] == STRING
    input.Body.hadoopJob.jarFileUris[_] == STRING
    input.Body.hadoopJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.hadoopJob.mainClass == STRING
    input.Body.hadoopJob.mainJarFileUri == STRING
    input.Body.hadoopJob.properties.STRING == STRING
    input.Body.hiveJob.continueOnFailure == BOOLEAN
    input.Body.hiveJob.jarFileUris[_] == STRING
    input.Body.hiveJob.properties.STRING == STRING
    input.Body.hiveJob.queryFileUri == STRING
    input.Body.hiveJob.queryList.queries[_] == STRING
    input.Body.hiveJob.scriptVariables.STRING == STRING
    input.Body.labels.STRING == STRING
    input.Body.pigJob.continueOnFailure == BOOLEAN
    input.Body.pigJob.jarFileUris[_] == STRING
    input.Body.pigJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.pigJob.properties.STRING == STRING
    input.Body.pigJob.queryFileUri == STRING
    input.Body.pigJob.queryList.queries[_] == STRING
    input.Body.pigJob.scriptVariables.STRING == STRING
    input.Body.placement.clusterLabels.STRING == STRING
    input.Body.placement.clusterName == STRING
    input.Body.prestoJob.clientTags[_] == STRING
    input.Body.prestoJob.continueOnFailure == BOOLEAN
    input.Body.prestoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.prestoJob.outputFormat == STRING
    input.Body.prestoJob.properties.STRING == STRING
    input.Body.prestoJob.queryFileUri == STRING
    input.Body.prestoJob.queryList.queries[_] == STRING
    input.Body.pysparkJob.archiveUris[_] == STRING
    input.Body.pysparkJob.args[_] == STRING
    input.Body.pysparkJob.fileUris[_] == STRING
    input.Body.pysparkJob.jarFileUris[_] == STRING
    input.Body.pysparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.pysparkJob.mainPythonFileUri == STRING
    input.Body.pysparkJob.properties.STRING == STRING
    input.Body.pysparkJob.pythonFileUris[_] == STRING
    input.Body.reference.jobId == STRING
    input.Body.reference.projectId == STRING
    input.Body.scheduling.maxFailuresPerHour == INTEGER
    input.Body.scheduling.maxFailuresTotal == INTEGER
    input.Body.sparkJob.archiveUris[_] == STRING
    input.Body.sparkJob.args[_] == STRING
    input.Body.sparkJob.fileUris[_] == STRING
    input.Body.sparkJob.jarFileUris[_] == STRING
    input.Body.sparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.sparkJob.mainClass == STRING
    input.Body.sparkJob.mainJarFileUri == STRING
    input.Body.sparkJob.properties.STRING == STRING
    input.Body.sparkRJob.archiveUris[_] == STRING
    input.Body.sparkRJob.args[_] == STRING
    input.Body.sparkRJob.fileUris[_] == STRING
    input.Body.sparkRJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.sparkRJob.mainRFileUri == STRING
    input.Body.sparkRJob.properties.STRING == STRING
    input.Body.sparkSqlJob.jarFileUris[_] == STRING
    input.Body.sparkSqlJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.sparkSqlJob.properties.STRING == STRING
    input.Body.sparkSqlJob.queryFileUri == STRING
    input.Body.sparkSqlJob.queryList.queries[_] == STRING
    input.Body.sparkSqlJob.scriptVariables.STRING == STRING
    input.Body.trinoJob.clientTags[_] == STRING
    input.Body.trinoJob.continueOnFailure == BOOLEAN
    input.Body.trinoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.trinoJob.outputFormat == STRING
    input.Body.trinoJob.properties.STRING == STRING
    input.Body.trinoJob.queryFileUri == STRING
    input.Body.trinoJob.queryList.queries[_] == STRING
    input.ReqMap.jobId == STRING
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.Qs.updateMask == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.jobs.setIamPolicy

valid {
    input.Body.policy.bindings[_].condition.description == STRING
    input.Body.policy.bindings[_].condition.expression == STRING
    input.Body.policy.bindings[_].condition.location == STRING
    input.Body.policy.bindings[_].condition.title == STRING
    input.Body.policy.bindings[_].members[_] == STRING
    input.Body.policy.bindings[_].role == STRING
    input.Body.policy.etag == STRING
    input.Body.policy.version == INTEGER
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.jobs.submit

enum_LoggingConfigDriverLogLevels := [ "LEVEL_UNSPECIFIED", "ALL", "TRACE", "DEBUG", "INFO", "WARN", "ERROR", "FATAL", "OFF" ]

valid {
    input.Body.job.driverSchedulingConfig.memoryMb == INTEGER
    input.Body.job.driverSchedulingConfig.vcores == INTEGER
    input.Body.job.flinkJob.args[_] == STRING
    input.Body.job.flinkJob.jarFileUris[_] == STRING
    input.Body.job.flinkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.flinkJob.mainClass == STRING
    input.Body.job.flinkJob.mainJarFileUri == STRING
    input.Body.job.flinkJob.properties.STRING == STRING
    input.Body.job.flinkJob.savepointUri == STRING
    input.Body.job.hadoopJob.archiveUris[_] == STRING
    input.Body.job.hadoopJob.args[_] == STRING
    input.Body.job.hadoopJob.fileUris[_] == STRING
    input.Body.job.hadoopJob.jarFileUris[_] == STRING
    input.Body.job.hadoopJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.hadoopJob.mainClass == STRING
    input.Body.job.hadoopJob.mainJarFileUri == STRING
    input.Body.job.hadoopJob.properties.STRING == STRING
    input.Body.job.hiveJob.continueOnFailure == BOOLEAN
    input.Body.job.hiveJob.jarFileUris[_] == STRING
    input.Body.job.hiveJob.properties.STRING == STRING
    input.Body.job.hiveJob.queryFileUri == STRING
    input.Body.job.hiveJob.queryList.queries[_] == STRING
    input.Body.job.hiveJob.scriptVariables.STRING == STRING
    input.Body.job.labels.STRING == STRING
    input.Body.job.pigJob.continueOnFailure == BOOLEAN
    input.Body.job.pigJob.jarFileUris[_] == STRING
    input.Body.job.pigJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.pigJob.properties.STRING == STRING
    input.Body.job.pigJob.queryFileUri == STRING
    input.Body.job.pigJob.queryList.queries[_] == STRING
    input.Body.job.pigJob.scriptVariables.STRING == STRING
    input.Body.job.placement.clusterLabels.STRING == STRING
    input.Body.job.placement.clusterName == STRING
    input.Body.job.prestoJob.clientTags[_] == STRING
    input.Body.job.prestoJob.continueOnFailure == BOOLEAN
    input.Body.job.prestoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.prestoJob.outputFormat == STRING
    input.Body.job.prestoJob.properties.STRING == STRING
    input.Body.job.prestoJob.queryFileUri == STRING
    input.Body.job.prestoJob.queryList.queries[_] == STRING
    input.Body.job.pysparkJob.archiveUris[_] == STRING
    input.Body.job.pysparkJob.args[_] == STRING
    input.Body.job.pysparkJob.fileUris[_] == STRING
    input.Body.job.pysparkJob.jarFileUris[_] == STRING
    input.Body.job.pysparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.pysparkJob.mainPythonFileUri == STRING
    input.Body.job.pysparkJob.properties.STRING == STRING
    input.Body.job.pysparkJob.pythonFileUris[_] == STRING
    input.Body.job.reference.jobId == STRING
    input.Body.job.reference.projectId == STRING
    input.Body.job.scheduling.maxFailuresPerHour == INTEGER
    input.Body.job.scheduling.maxFailuresTotal == INTEGER
    input.Body.job.sparkJob.archiveUris[_] == STRING
    input.Body.job.sparkJob.args[_] == STRING
    input.Body.job.sparkJob.fileUris[_] == STRING
    input.Body.job.sparkJob.jarFileUris[_] == STRING
    input.Body.job.sparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.sparkJob.mainClass == STRING
    input.Body.job.sparkJob.mainJarFileUri == STRING
    input.Body.job.sparkJob.properties.STRING == STRING
    input.Body.job.sparkRJob.archiveUris[_] == STRING
    input.Body.job.sparkRJob.args[_] == STRING
    input.Body.job.sparkRJob.fileUris[_] == STRING
    input.Body.job.sparkRJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.sparkRJob.mainRFileUri == STRING
    input.Body.job.sparkRJob.properties.STRING == STRING
    input.Body.job.sparkSqlJob.jarFileUris[_] == STRING
    input.Body.job.sparkSqlJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.sparkSqlJob.properties.STRING == STRING
    input.Body.job.sparkSqlJob.queryFileUri == STRING
    input.Body.job.sparkSqlJob.queryList.queries[_] == STRING
    input.Body.job.sparkSqlJob.scriptVariables.STRING == STRING
    input.Body.job.trinoJob.clientTags[_] == STRING
    input.Body.job.trinoJob.continueOnFailure == BOOLEAN
    input.Body.job.trinoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.trinoJob.outputFormat == STRING
    input.Body.job.trinoJob.properties.STRING == STRING
    input.Body.job.trinoJob.queryFileUri == STRING
    input.Body.job.trinoJob.queryList.queries[_] == STRING
    input.Body.requestId == STRING
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.jobs.submitAsOperation

enum_LoggingConfigDriverLogLevels := [ "LEVEL_UNSPECIFIED", "ALL", "TRACE", "DEBUG", "INFO", "WARN", "ERROR", "FATAL", "OFF" ]

valid {
    input.Body.job.driverSchedulingConfig.memoryMb == INTEGER
    input.Body.job.driverSchedulingConfig.vcores == INTEGER
    input.Body.job.flinkJob.args[_] == STRING
    input.Body.job.flinkJob.jarFileUris[_] == STRING
    input.Body.job.flinkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.flinkJob.mainClass == STRING
    input.Body.job.flinkJob.mainJarFileUri == STRING
    input.Body.job.flinkJob.properties.STRING == STRING
    input.Body.job.flinkJob.savepointUri == STRING
    input.Body.job.hadoopJob.archiveUris[_] == STRING
    input.Body.job.hadoopJob.args[_] == STRING
    input.Body.job.hadoopJob.fileUris[_] == STRING
    input.Body.job.hadoopJob.jarFileUris[_] == STRING
    input.Body.job.hadoopJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.hadoopJob.mainClass == STRING
    input.Body.job.hadoopJob.mainJarFileUri == STRING
    input.Body.job.hadoopJob.properties.STRING == STRING
    input.Body.job.hiveJob.continueOnFailure == BOOLEAN
    input.Body.job.hiveJob.jarFileUris[_] == STRING
    input.Body.job.hiveJob.properties.STRING == STRING
    input.Body.job.hiveJob.queryFileUri == STRING
    input.Body.job.hiveJob.queryList.queries[_] == STRING
    input.Body.job.hiveJob.scriptVariables.STRING == STRING
    input.Body.job.labels.STRING == STRING
    input.Body.job.pigJob.continueOnFailure == BOOLEAN
    input.Body.job.pigJob.jarFileUris[_] == STRING
    input.Body.job.pigJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.pigJob.properties.STRING == STRING
    input.Body.job.pigJob.queryFileUri == STRING
    input.Body.job.pigJob.queryList.queries[_] == STRING
    input.Body.job.pigJob.scriptVariables.STRING == STRING
    input.Body.job.placement.clusterLabels.STRING == STRING
    input.Body.job.placement.clusterName == STRING
    input.Body.job.prestoJob.clientTags[_] == STRING
    input.Body.job.prestoJob.continueOnFailure == BOOLEAN
    input.Body.job.prestoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.prestoJob.outputFormat == STRING
    input.Body.job.prestoJob.properties.STRING == STRING
    input.Body.job.prestoJob.queryFileUri == STRING
    input.Body.job.prestoJob.queryList.queries[_] == STRING
    input.Body.job.pysparkJob.archiveUris[_] == STRING
    input.Body.job.pysparkJob.args[_] == STRING
    input.Body.job.pysparkJob.fileUris[_] == STRING
    input.Body.job.pysparkJob.jarFileUris[_] == STRING
    input.Body.job.pysparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.pysparkJob.mainPythonFileUri == STRING
    input.Body.job.pysparkJob.properties.STRING == STRING
    input.Body.job.pysparkJob.pythonFileUris[_] == STRING
    input.Body.job.reference.jobId == STRING
    input.Body.job.reference.projectId == STRING
    input.Body.job.scheduling.maxFailuresPerHour == INTEGER
    input.Body.job.scheduling.maxFailuresTotal == INTEGER
    input.Body.job.sparkJob.archiveUris[_] == STRING
    input.Body.job.sparkJob.args[_] == STRING
    input.Body.job.sparkJob.fileUris[_] == STRING
    input.Body.job.sparkJob.jarFileUris[_] == STRING
    input.Body.job.sparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.sparkJob.mainClass == STRING
    input.Body.job.sparkJob.mainJarFileUri == STRING
    input.Body.job.sparkJob.properties.STRING == STRING
    input.Body.job.sparkRJob.archiveUris[_] == STRING
    input.Body.job.sparkRJob.args[_] == STRING
    input.Body.job.sparkRJob.fileUris[_] == STRING
    input.Body.job.sparkRJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.sparkRJob.mainRFileUri == STRING
    input.Body.job.sparkRJob.properties.STRING == STRING
    input.Body.job.sparkSqlJob.jarFileUris[_] == STRING
    input.Body.job.sparkSqlJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.sparkSqlJob.properties.STRING == STRING
    input.Body.job.sparkSqlJob.queryFileUri == STRING
    input.Body.job.sparkSqlJob.queryList.queries[_] == STRING
    input.Body.job.sparkSqlJob.scriptVariables.STRING == STRING
    input.Body.job.trinoJob.clientTags[_] == STRING
    input.Body.job.trinoJob.continueOnFailure == BOOLEAN
    input.Body.job.trinoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.job.trinoJob.outputFormat == STRING
    input.Body.job.trinoJob.properties.STRING == STRING
    input.Body.job.trinoJob.queryFileUri == STRING
    input.Body.job.trinoJob.queryList.queries[_] == STRING
    input.Body.requestId == STRING
    input.ReqMap.ProjectID == STRING
    input.ReqMap.region == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.ProjectID == STRING
}

dataproc.projects.regions.jobs.testIamPermissions

valid {
    input.Body.permissions[_] == STRING
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.operations.cancel

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.operations.delete

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.operations.get

valid {
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.operations.getIamPolicy

valid {
    input.Body.options.requestedPolicyVersion == INTEGER
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.operations.list

valid {
    input.ReqMap.name == STRING
    input.Qs.filter == STRING
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.operations.setIamPolicy

valid {
    input.Body.policy.bindings[_].condition.description == STRING
    input.Body.policy.bindings[_].condition.expression == STRING
    input.Body.policy.bindings[_].condition.location == STRING
    input.Body.policy.bindings[_].condition.title == STRING
    input.Body.policy.bindings[_].members[_] == STRING
    input.Body.policy.bindings[_].role == STRING
    input.Body.policy.etag == STRING
    input.Body.policy.version == INTEGER
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.operations.testIamPermissions

valid {
    input.Body.permissions[_] == STRING
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.workflowTemplates.create

enum_GceClusterConfigPrivateIpv6GoogleAccess := [ "PRIVATE_IPV6_GOOGLE_ACCESS_UNSPECIFIED", "INHERIT_FROM_SUBNETWORK", "OUTBOUND", "BIDIRECTIONAL" ]
enum_GkeNodePoolTargetRoles := [ "ROLE_UNSPECIFIED", "DEFAULT", "CONTROLLER", "SPARK_DRIVER", "SPARK_EXECUTOR" ]
enum_InstanceGroupConfigPreemptibility := [ "PREEMPTIBILITY_UNSPECIFIED", "NON_PREEMPTIBLE", "PREEMPTIBLE", "SPOT" ]
enum_LoggingConfigDriverLogLevels := [ "LEVEL_UNSPECIFIED", "ALL", "TRACE", "DEBUG", "INFO", "WARN", "ERROR", "FATAL", "OFF" ]
enum_MetricMetricSource := [ "METRIC_SOURCE_UNSPECIFIED", "MONITORING_AGENT_DEFAULTS", "HDFS", "SPARK", "YARN", "SPARK_HISTORY_SERVER", "HIVESERVER2", "HIVEMETASTORE", "FLINK" ]
enum_NodeGroupRoles := [ "ROLE_UNSPECIFIED", "DRIVER" ]
enum_ReservationAffinityConsumeReservationType := [ "TYPE_UNSPECIFIED", "NO_RESERVATION", "ANY_RESERVATION", "SPECIFIC_RESERVATION" ]
enum_SoftwareConfigOptionalComponents := [ "COMPONENT_UNSPECIFIED", "ANACONDA", "DOCKER", "DRUID", "FLINK", "HBASE", "HIVE_WEBHCAT", "HUDI", "JUPYTER", "PRESTO", "TRINO", "RANGER", "SOLR", "ZEPPELIN", "ZOOKEEPER" ]

valid {
    input.Body.dagTimeout == STRING
    input.Body.encryptionConfig.kmsKey == STRING
    input.Body.id == STRING
    input.Body.jobs[_].flinkJob.args[_] == STRING
    input.Body.jobs[_].flinkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].flinkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].flinkJob.mainClass == STRING
    input.Body.jobs[_].flinkJob.mainJarFileUri == STRING
    input.Body.jobs[_].flinkJob.properties.STRING == STRING
    input.Body.jobs[_].flinkJob.savepointUri == STRING
    input.Body.jobs[_].hadoopJob.archiveUris[_] == STRING
    input.Body.jobs[_].hadoopJob.args[_] == STRING
    input.Body.jobs[_].hadoopJob.fileUris[_] == STRING
    input.Body.jobs[_].hadoopJob.jarFileUris[_] == STRING
    input.Body.jobs[_].hadoopJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].hadoopJob.mainClass == STRING
    input.Body.jobs[_].hadoopJob.mainJarFileUri == STRING
    input.Body.jobs[_].hadoopJob.properties.STRING == STRING
    input.Body.jobs[_].hiveJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].hiveJob.jarFileUris[_] == STRING
    input.Body.jobs[_].hiveJob.properties.STRING == STRING
    input.Body.jobs[_].hiveJob.queryFileUri == STRING
    input.Body.jobs[_].hiveJob.queryList.queries[_] == STRING
    input.Body.jobs[_].hiveJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].labels.STRING == STRING
    input.Body.jobs[_].pigJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].pigJob.jarFileUris[_] == STRING
    input.Body.jobs[_].pigJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].pigJob.properties.STRING == STRING
    input.Body.jobs[_].pigJob.queryFileUri == STRING
    input.Body.jobs[_].pigJob.queryList.queries[_] == STRING
    input.Body.jobs[_].pigJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].prerequisiteStepIds[_] == STRING
    input.Body.jobs[_].prestoJob.clientTags[_] == STRING
    input.Body.jobs[_].prestoJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].prestoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].prestoJob.outputFormat == STRING
    input.Body.jobs[_].prestoJob.properties.STRING == STRING
    input.Body.jobs[_].prestoJob.queryFileUri == STRING
    input.Body.jobs[_].prestoJob.queryList.queries[_] == STRING
    input.Body.jobs[_].pysparkJob.archiveUris[_] == STRING
    input.Body.jobs[_].pysparkJob.args[_] == STRING
    input.Body.jobs[_].pysparkJob.fileUris[_] == STRING
    input.Body.jobs[_].pysparkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].pysparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].pysparkJob.mainPythonFileUri == STRING
    input.Body.jobs[_].pysparkJob.properties.STRING == STRING
    input.Body.jobs[_].pysparkJob.pythonFileUris[_] == STRING
    input.Body.jobs[_].scheduling.maxFailuresPerHour == INTEGER
    input.Body.jobs[_].scheduling.maxFailuresTotal == INTEGER
    input.Body.jobs[_].sparkJob.archiveUris[_] == STRING
    input.Body.jobs[_].sparkJob.args[_] == STRING
    input.Body.jobs[_].sparkJob.fileUris[_] == STRING
    input.Body.jobs[_].sparkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].sparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkJob.mainClass == STRING
    input.Body.jobs[_].sparkJob.mainJarFileUri == STRING
    input.Body.jobs[_].sparkJob.properties.STRING == STRING
    input.Body.jobs[_].sparkRJob.archiveUris[_] == STRING
    input.Body.jobs[_].sparkRJob.args[_] == STRING
    input.Body.jobs[_].sparkRJob.fileUris[_] == STRING
    input.Body.jobs[_].sparkRJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkRJob.mainRFileUri == STRING
    input.Body.jobs[_].sparkRJob.properties.STRING == STRING
    input.Body.jobs[_].sparkSqlJob.jarFileUris[_] == STRING
    input.Body.jobs[_].sparkSqlJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkSqlJob.properties.STRING == STRING
    input.Body.jobs[_].sparkSqlJob.queryFileUri == STRING
    input.Body.jobs[_].sparkSqlJob.queryList.queries[_] == STRING
    input.Body.jobs[_].sparkSqlJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].stepId == STRING
    input.Body.jobs[_].trinoJob.clientTags[_] == STRING
    input.Body.jobs[_].trinoJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].trinoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].trinoJob.outputFormat == STRING
    input.Body.jobs[_].trinoJob.properties.STRING == STRING
    input.Body.jobs[_].trinoJob.queryFileUri == STRING
    input.Body.jobs[_].trinoJob.queryList.queries[_] == STRING
    input.Body.labels.STRING == STRING
    input.Body.parameters[_].description == STRING
    input.Body.parameters[_].fields[_] == STRING
    input.Body.parameters[_].name == STRING
    input.Body.parameters[_].validation.regex.regexes[_] == STRING
    input.Body.parameters[_].validation.values.values[_] == STRING
    input.Body.placement.clusterSelector.clusterLabels.STRING == STRING
    input.Body.placement.clusterSelector.zone == STRING
    input.Body.placement.managedCluster.clusterName == STRING
    input.Body.placement.managedCluster.config.autoscalingConfig.policyUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.labels.STRING == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.name == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.roles[_] == enum_NodeGroupRoles[_]
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroupId == STRING
    input.Body.placement.managedCluster.config.configBucket == STRING
    input.Body.placement.managedCluster.config.dataprocMetricConfig.metrics[_].metricOverrides[_] == STRING
    input.Body.placement.managedCluster.config.dataprocMetricConfig.metrics[_].metricSource == enum_MetricMetricSource[_]
    input.Body.placement.managedCluster.config.encryptionConfig.gcePdKmsKeyName == STRING
    input.Body.placement.managedCluster.config.encryptionConfig.kmsKey == STRING
    input.Body.placement.managedCluster.config.endpointConfig.enableHttpPortAccess == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.confidentialInstanceConfig.enableConfidentialCompute == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.internalIpOnly == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.metadata.STRING == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.networkUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.nodeGroupAffinity.nodeGroupUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.privateIpv6GoogleAccess == enum_GceClusterConfigPrivateIpv6GoogleAccess[_]
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.consumeReservationType == enum_ReservationAffinityConsumeReservationType[_]
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.key == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.values[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.serviceAccount == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.serviceAccountScopes[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableIntegrityMonitoring == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableSecureBoot == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableVtpm == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.subnetworkUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.tags[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.zoneUri == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.gkeClusterTarget == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.namespacedGkeDeploymentTarget.clusterNamespace == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.namespacedGkeDeploymentTarget.targetGkeCluster == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePool == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.maxNodeCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.minNodeCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorCount == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorType == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].gpuPartitionSize == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.bootDiskKmsKey == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.localSsdCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.machineType == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.preemptible == BOOLEAN
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.spot == BOOLEAN
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.locations[_] == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].roles[_] == enum_GkeNodePoolTargetRoles[_]
    input.Body.placement.managedCluster.config.initializationActions[_].executableFile == STRING
    input.Body.placement.managedCluster.config.initializationActions[_].executionTimeout == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.autoDeleteTime == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.autoDeleteTtl == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.idleDeleteTtl == STRING
    input.Body.placement.managedCluster.config.masterConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.masterConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.masterConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.metastoreConfig.dataprocMetastoreService == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.securityConfig.identityConfig.userServiceAccountMapping.STRING == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustAdminServer == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustKdc == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustRealm == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustSharedPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.enableKerberos == BOOLEAN
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.kdcDbKeyUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keyPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keystorePasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keystoreUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.kmsKeyUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.realm == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.rootPrincipalPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.tgtLifetimeHours == INTEGER
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.truststorePasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.truststoreUri == STRING
    input.Body.placement.managedCluster.config.softwareConfig.imageVersion == STRING
    input.Body.placement.managedCluster.config.softwareConfig.optionalComponents[_] == enum_SoftwareConfigOptionalComponents[_]
    input.Body.placement.managedCluster.config.softwareConfig.properties.STRING == STRING
    input.Body.placement.managedCluster.config.tempBucket == STRING
    input.Body.placement.managedCluster.config.workerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.workerConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.workerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.labels.STRING == STRING
    input.Body.version == INTEGER
    input.ReqMap.parent == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.workflowTemplates.delete

valid {
    input.ReqMap.name == STRING
    input.Qs.version == INTEGER
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.workflowTemplates.get

valid {
    input.ReqMap.name == STRING
    input.Qs.version == INTEGER
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.workflowTemplates.getIamPolicy

valid {
    input.Body.options.requestedPolicyVersion == INTEGER
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.workflowTemplates.instantiate

valid {
    input.Body.parameters.STRING == STRING
    input.Body.requestId == STRING
    input.Body.version == INTEGER
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.workflowTemplates.instantiateInline

enum_GceClusterConfigPrivateIpv6GoogleAccess := [ "PRIVATE_IPV6_GOOGLE_ACCESS_UNSPECIFIED", "INHERIT_FROM_SUBNETWORK", "OUTBOUND", "BIDIRECTIONAL" ]
enum_GkeNodePoolTargetRoles := [ "ROLE_UNSPECIFIED", "DEFAULT", "CONTROLLER", "SPARK_DRIVER", "SPARK_EXECUTOR" ]
enum_InstanceGroupConfigPreemptibility := [ "PREEMPTIBILITY_UNSPECIFIED", "NON_PREEMPTIBLE", "PREEMPTIBLE", "SPOT" ]
enum_LoggingConfigDriverLogLevels := [ "LEVEL_UNSPECIFIED", "ALL", "TRACE", "DEBUG", "INFO", "WARN", "ERROR", "FATAL", "OFF" ]
enum_MetricMetricSource := [ "METRIC_SOURCE_UNSPECIFIED", "MONITORING_AGENT_DEFAULTS", "HDFS", "SPARK", "YARN", "SPARK_HISTORY_SERVER", "HIVESERVER2", "HIVEMETASTORE", "FLINK" ]
enum_NodeGroupRoles := [ "ROLE_UNSPECIFIED", "DRIVER" ]
enum_ReservationAffinityConsumeReservationType := [ "TYPE_UNSPECIFIED", "NO_RESERVATION", "ANY_RESERVATION", "SPECIFIC_RESERVATION" ]
enum_SoftwareConfigOptionalComponents := [ "COMPONENT_UNSPECIFIED", "ANACONDA", "DOCKER", "DRUID", "FLINK", "HBASE", "HIVE_WEBHCAT", "HUDI", "JUPYTER", "PRESTO", "TRINO", "RANGER", "SOLR", "ZEPPELIN", "ZOOKEEPER" ]

valid {
    input.Body.dagTimeout == STRING
    input.Body.encryptionConfig.kmsKey == STRING
    input.Body.id == STRING
    input.Body.jobs[_].flinkJob.args[_] == STRING
    input.Body.jobs[_].flinkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].flinkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].flinkJob.mainClass == STRING
    input.Body.jobs[_].flinkJob.mainJarFileUri == STRING
    input.Body.jobs[_].flinkJob.properties.STRING == STRING
    input.Body.jobs[_].flinkJob.savepointUri == STRING
    input.Body.jobs[_].hadoopJob.archiveUris[_] == STRING
    input.Body.jobs[_].hadoopJob.args[_] == STRING
    input.Body.jobs[_].hadoopJob.fileUris[_] == STRING
    input.Body.jobs[_].hadoopJob.jarFileUris[_] == STRING
    input.Body.jobs[_].hadoopJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].hadoopJob.mainClass == STRING
    input.Body.jobs[_].hadoopJob.mainJarFileUri == STRING
    input.Body.jobs[_].hadoopJob.properties.STRING == STRING
    input.Body.jobs[_].hiveJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].hiveJob.jarFileUris[_] == STRING
    input.Body.jobs[_].hiveJob.properties.STRING == STRING
    input.Body.jobs[_].hiveJob.queryFileUri == STRING
    input.Body.jobs[_].hiveJob.queryList.queries[_] == STRING
    input.Body.jobs[_].hiveJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].labels.STRING == STRING
    input.Body.jobs[_].pigJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].pigJob.jarFileUris[_] == STRING
    input.Body.jobs[_].pigJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].pigJob.properties.STRING == STRING
    input.Body.jobs[_].pigJob.queryFileUri == STRING
    input.Body.jobs[_].pigJob.queryList.queries[_] == STRING
    input.Body.jobs[_].pigJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].prerequisiteStepIds[_] == STRING
    input.Body.jobs[_].prestoJob.clientTags[_] == STRING
    input.Body.jobs[_].prestoJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].prestoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].prestoJob.outputFormat == STRING
    input.Body.jobs[_].prestoJob.properties.STRING == STRING
    input.Body.jobs[_].prestoJob.queryFileUri == STRING
    input.Body.jobs[_].prestoJob.queryList.queries[_] == STRING
    input.Body.jobs[_].pysparkJob.archiveUris[_] == STRING
    input.Body.jobs[_].pysparkJob.args[_] == STRING
    input.Body.jobs[_].pysparkJob.fileUris[_] == STRING
    input.Body.jobs[_].pysparkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].pysparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].pysparkJob.mainPythonFileUri == STRING
    input.Body.jobs[_].pysparkJob.properties.STRING == STRING
    input.Body.jobs[_].pysparkJob.pythonFileUris[_] == STRING
    input.Body.jobs[_].scheduling.maxFailuresPerHour == INTEGER
    input.Body.jobs[_].scheduling.maxFailuresTotal == INTEGER
    input.Body.jobs[_].sparkJob.archiveUris[_] == STRING
    input.Body.jobs[_].sparkJob.args[_] == STRING
    input.Body.jobs[_].sparkJob.fileUris[_] == STRING
    input.Body.jobs[_].sparkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].sparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkJob.mainClass == STRING
    input.Body.jobs[_].sparkJob.mainJarFileUri == STRING
    input.Body.jobs[_].sparkJob.properties.STRING == STRING
    input.Body.jobs[_].sparkRJob.archiveUris[_] == STRING
    input.Body.jobs[_].sparkRJob.args[_] == STRING
    input.Body.jobs[_].sparkRJob.fileUris[_] == STRING
    input.Body.jobs[_].sparkRJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkRJob.mainRFileUri == STRING
    input.Body.jobs[_].sparkRJob.properties.STRING == STRING
    input.Body.jobs[_].sparkSqlJob.jarFileUris[_] == STRING
    input.Body.jobs[_].sparkSqlJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkSqlJob.properties.STRING == STRING
    input.Body.jobs[_].sparkSqlJob.queryFileUri == STRING
    input.Body.jobs[_].sparkSqlJob.queryList.queries[_] == STRING
    input.Body.jobs[_].sparkSqlJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].stepId == STRING
    input.Body.jobs[_].trinoJob.clientTags[_] == STRING
    input.Body.jobs[_].trinoJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].trinoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].trinoJob.outputFormat == STRING
    input.Body.jobs[_].trinoJob.properties.STRING == STRING
    input.Body.jobs[_].trinoJob.queryFileUri == STRING
    input.Body.jobs[_].trinoJob.queryList.queries[_] == STRING
    input.Body.labels.STRING == STRING
    input.Body.parameters[_].description == STRING
    input.Body.parameters[_].fields[_] == STRING
    input.Body.parameters[_].name == STRING
    input.Body.parameters[_].validation.regex.regexes[_] == STRING
    input.Body.parameters[_].validation.values.values[_] == STRING
    input.Body.placement.clusterSelector.clusterLabels.STRING == STRING
    input.Body.placement.clusterSelector.zone == STRING
    input.Body.placement.managedCluster.clusterName == STRING
    input.Body.placement.managedCluster.config.autoscalingConfig.policyUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.labels.STRING == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.name == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.roles[_] == enum_NodeGroupRoles[_]
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroupId == STRING
    input.Body.placement.managedCluster.config.configBucket == STRING
    input.Body.placement.managedCluster.config.dataprocMetricConfig.metrics[_].metricOverrides[_] == STRING
    input.Body.placement.managedCluster.config.dataprocMetricConfig.metrics[_].metricSource == enum_MetricMetricSource[_]
    input.Body.placement.managedCluster.config.encryptionConfig.gcePdKmsKeyName == STRING
    input.Body.placement.managedCluster.config.encryptionConfig.kmsKey == STRING
    input.Body.placement.managedCluster.config.endpointConfig.enableHttpPortAccess == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.confidentialInstanceConfig.enableConfidentialCompute == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.internalIpOnly == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.metadata.STRING == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.networkUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.nodeGroupAffinity.nodeGroupUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.privateIpv6GoogleAccess == enum_GceClusterConfigPrivateIpv6GoogleAccess[_]
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.consumeReservationType == enum_ReservationAffinityConsumeReservationType[_]
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.key == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.values[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.serviceAccount == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.serviceAccountScopes[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableIntegrityMonitoring == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableSecureBoot == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableVtpm == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.subnetworkUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.tags[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.zoneUri == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.gkeClusterTarget == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.namespacedGkeDeploymentTarget.clusterNamespace == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.namespacedGkeDeploymentTarget.targetGkeCluster == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePool == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.maxNodeCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.minNodeCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorCount == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorType == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].gpuPartitionSize == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.bootDiskKmsKey == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.localSsdCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.machineType == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.preemptible == BOOLEAN
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.spot == BOOLEAN
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.locations[_] == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].roles[_] == enum_GkeNodePoolTargetRoles[_]
    input.Body.placement.managedCluster.config.initializationActions[_].executableFile == STRING
    input.Body.placement.managedCluster.config.initializationActions[_].executionTimeout == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.autoDeleteTime == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.autoDeleteTtl == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.idleDeleteTtl == STRING
    input.Body.placement.managedCluster.config.masterConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.masterConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.masterConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.metastoreConfig.dataprocMetastoreService == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.securityConfig.identityConfig.userServiceAccountMapping.STRING == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustAdminServer == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustKdc == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustRealm == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustSharedPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.enableKerberos == BOOLEAN
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.kdcDbKeyUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keyPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keystorePasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keystoreUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.kmsKeyUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.realm == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.rootPrincipalPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.tgtLifetimeHours == INTEGER
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.truststorePasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.truststoreUri == STRING
    input.Body.placement.managedCluster.config.softwareConfig.imageVersion == STRING
    input.Body.placement.managedCluster.config.softwareConfig.optionalComponents[_] == enum_SoftwareConfigOptionalComponents[_]
    input.Body.placement.managedCluster.config.softwareConfig.properties.STRING == STRING
    input.Body.placement.managedCluster.config.tempBucket == STRING
    input.Body.placement.managedCluster.config.workerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.workerConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.workerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.labels.STRING == STRING
    input.Body.version == INTEGER
    input.ReqMap.parent == STRING
    input.Qs.requestId == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.workflowTemplates.list

valid {
    input.ReqMap.parent == STRING
    input.Qs.pageSize == INTEGER
    input.Qs.pageToken == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.workflowTemplates.setIamPolicy

valid {
    input.Body.policy.bindings[_].condition.description == STRING
    input.Body.policy.bindings[_].condition.expression == STRING
    input.Body.policy.bindings[_].condition.location == STRING
    input.Body.policy.bindings[_].condition.title == STRING
    input.Body.policy.bindings[_].members[_] == STRING
    input.Body.policy.bindings[_].role == STRING
    input.Body.policy.etag == STRING
    input.Body.policy.version == INTEGER
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.workflowTemplates.testIamPermissions

valid {
    input.Body.permissions[_] == STRING
    input.ReqMap.resource == STRING
    input.ProviderMetadata.Region == STRING
}

dataproc.projects.regions.workflowTemplates.update

enum_GceClusterConfigPrivateIpv6GoogleAccess := [ "PRIVATE_IPV6_GOOGLE_ACCESS_UNSPECIFIED", "INHERIT_FROM_SUBNETWORK", "OUTBOUND", "BIDIRECTIONAL" ]
enum_GkeNodePoolTargetRoles := [ "ROLE_UNSPECIFIED", "DEFAULT", "CONTROLLER", "SPARK_DRIVER", "SPARK_EXECUTOR" ]
enum_InstanceGroupConfigPreemptibility := [ "PREEMPTIBILITY_UNSPECIFIED", "NON_PREEMPTIBLE", "PREEMPTIBLE", "SPOT" ]
enum_LoggingConfigDriverLogLevels := [ "LEVEL_UNSPECIFIED", "ALL", "TRACE", "DEBUG", "INFO", "WARN", "ERROR", "FATAL", "OFF" ]
enum_MetricMetricSource := [ "METRIC_SOURCE_UNSPECIFIED", "MONITORING_AGENT_DEFAULTS", "HDFS", "SPARK", "YARN", "SPARK_HISTORY_SERVER", "HIVESERVER2", "HIVEMETASTORE", "FLINK" ]
enum_NodeGroupRoles := [ "ROLE_UNSPECIFIED", "DRIVER" ]
enum_ReservationAffinityConsumeReservationType := [ "TYPE_UNSPECIFIED", "NO_RESERVATION", "ANY_RESERVATION", "SPECIFIC_RESERVATION" ]
enum_SoftwareConfigOptionalComponents := [ "COMPONENT_UNSPECIFIED", "ANACONDA", "DOCKER", "DRUID", "FLINK", "HBASE", "HIVE_WEBHCAT", "HUDI", "JUPYTER", "PRESTO", "TRINO", "RANGER", "SOLR", "ZEPPELIN", "ZOOKEEPER" ]

valid {
    input.Body.dagTimeout == STRING
    input.Body.encryptionConfig.kmsKey == STRING
    input.Body.id == STRING
    input.Body.jobs[_].flinkJob.args[_] == STRING
    input.Body.jobs[_].flinkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].flinkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].flinkJob.mainClass == STRING
    input.Body.jobs[_].flinkJob.mainJarFileUri == STRING
    input.Body.jobs[_].flinkJob.properties.STRING == STRING
    input.Body.jobs[_].flinkJob.savepointUri == STRING
    input.Body.jobs[_].hadoopJob.archiveUris[_] == STRING
    input.Body.jobs[_].hadoopJob.args[_] == STRING
    input.Body.jobs[_].hadoopJob.fileUris[_] == STRING
    input.Body.jobs[_].hadoopJob.jarFileUris[_] == STRING
    input.Body.jobs[_].hadoopJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].hadoopJob.mainClass == STRING
    input.Body.jobs[_].hadoopJob.mainJarFileUri == STRING
    input.Body.jobs[_].hadoopJob.properties.STRING == STRING
    input.Body.jobs[_].hiveJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].hiveJob.jarFileUris[_] == STRING
    input.Body.jobs[_].hiveJob.properties.STRING == STRING
    input.Body.jobs[_].hiveJob.queryFileUri == STRING
    input.Body.jobs[_].hiveJob.queryList.queries[_] == STRING
    input.Body.jobs[_].hiveJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].labels.STRING == STRING
    input.Body.jobs[_].pigJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].pigJob.jarFileUris[_] == STRING
    input.Body.jobs[_].pigJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].pigJob.properties.STRING == STRING
    input.Body.jobs[_].pigJob.queryFileUri == STRING
    input.Body.jobs[_].pigJob.queryList.queries[_] == STRING
    input.Body.jobs[_].pigJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].prerequisiteStepIds[_] == STRING
    input.Body.jobs[_].prestoJob.clientTags[_] == STRING
    input.Body.jobs[_].prestoJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].prestoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].prestoJob.outputFormat == STRING
    input.Body.jobs[_].prestoJob.properties.STRING == STRING
    input.Body.jobs[_].prestoJob.queryFileUri == STRING
    input.Body.jobs[_].prestoJob.queryList.queries[_] == STRING
    input.Body.jobs[_].pysparkJob.archiveUris[_] == STRING
    input.Body.jobs[_].pysparkJob.args[_] == STRING
    input.Body.jobs[_].pysparkJob.fileUris[_] == STRING
    input.Body.jobs[_].pysparkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].pysparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].pysparkJob.mainPythonFileUri == STRING
    input.Body.jobs[_].pysparkJob.properties.STRING == STRING
    input.Body.jobs[_].pysparkJob.pythonFileUris[_] == STRING
    input.Body.jobs[_].scheduling.maxFailuresPerHour == INTEGER
    input.Body.jobs[_].scheduling.maxFailuresTotal == INTEGER
    input.Body.jobs[_].sparkJob.archiveUris[_] == STRING
    input.Body.jobs[_].sparkJob.args[_] == STRING
    input.Body.jobs[_].sparkJob.fileUris[_] == STRING
    input.Body.jobs[_].sparkJob.jarFileUris[_] == STRING
    input.Body.jobs[_].sparkJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkJob.mainClass == STRING
    input.Body.jobs[_].sparkJob.mainJarFileUri == STRING
    input.Body.jobs[_].sparkJob.properties.STRING == STRING
    input.Body.jobs[_].sparkRJob.archiveUris[_] == STRING
    input.Body.jobs[_].sparkRJob.args[_] == STRING
    input.Body.jobs[_].sparkRJob.fileUris[_] == STRING
    input.Body.jobs[_].sparkRJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkRJob.mainRFileUri == STRING
    input.Body.jobs[_].sparkRJob.properties.STRING == STRING
    input.Body.jobs[_].sparkSqlJob.jarFileUris[_] == STRING
    input.Body.jobs[_].sparkSqlJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].sparkSqlJob.properties.STRING == STRING
    input.Body.jobs[_].sparkSqlJob.queryFileUri == STRING
    input.Body.jobs[_].sparkSqlJob.queryList.queries[_] == STRING
    input.Body.jobs[_].sparkSqlJob.scriptVariables.STRING == STRING
    input.Body.jobs[_].stepId == STRING
    input.Body.jobs[_].trinoJob.clientTags[_] == STRING
    input.Body.jobs[_].trinoJob.continueOnFailure == BOOLEAN
    input.Body.jobs[_].trinoJob.loggingConfig.driverLogLevels.STRING == enum_LoggingConfigDriverLogLevels[_]
    input.Body.jobs[_].trinoJob.outputFormat == STRING
    input.Body.jobs[_].trinoJob.properties.STRING == STRING
    input.Body.jobs[_].trinoJob.queryFileUri == STRING
    input.Body.jobs[_].trinoJob.queryList.queries[_] == STRING
    input.Body.labels.STRING == STRING
    input.Body.parameters[_].description == STRING
    input.Body.parameters[_].fields[_] == STRING
    input.Body.parameters[_].name == STRING
    input.Body.parameters[_].validation.regex.regexes[_] == STRING
    input.Body.parameters[_].validation.values.values[_] == STRING
    input.Body.placement.clusterSelector.clusterLabels.STRING == STRING
    input.Body.placement.clusterSelector.zone == STRING
    input.Body.placement.managedCluster.clusterName == STRING
    input.Body.placement.managedCluster.config.autoscalingConfig.policyUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.labels.STRING == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.name == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.nodeGroupConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroup.roles[_] == enum_NodeGroupRoles[_]
    input.Body.placement.managedCluster.config.auxiliaryNodeGroups[_].nodeGroupId == STRING
    input.Body.placement.managedCluster.config.configBucket == STRING
    input.Body.placement.managedCluster.config.dataprocMetricConfig.metrics[_].metricOverrides[_] == STRING
    input.Body.placement.managedCluster.config.dataprocMetricConfig.metrics[_].metricSource == enum_MetricMetricSource[_]
    input.Body.placement.managedCluster.config.encryptionConfig.gcePdKmsKeyName == STRING
    input.Body.placement.managedCluster.config.encryptionConfig.kmsKey == STRING
    input.Body.placement.managedCluster.config.endpointConfig.enableHttpPortAccess == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.confidentialInstanceConfig.enableConfidentialCompute == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.internalIpOnly == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.metadata.STRING == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.networkUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.nodeGroupAffinity.nodeGroupUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.privateIpv6GoogleAccess == enum_GceClusterConfigPrivateIpv6GoogleAccess[_]
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.consumeReservationType == enum_ReservationAffinityConsumeReservationType[_]
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.key == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.reservationAffinity.values[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.serviceAccount == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.serviceAccountScopes[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableIntegrityMonitoring == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableSecureBoot == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.shieldedInstanceConfig.enableVtpm == BOOLEAN
    input.Body.placement.managedCluster.config.gceClusterConfig.subnetworkUri == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.tags[_] == STRING
    input.Body.placement.managedCluster.config.gceClusterConfig.zoneUri == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.gkeClusterTarget == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.namespacedGkeDeploymentTarget.clusterNamespace == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.namespacedGkeDeploymentTarget.targetGkeCluster == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePool == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.maxNodeCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.autoscaling.minNodeCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorCount == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].acceleratorType == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.accelerators[_].gpuPartitionSize == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.bootDiskKmsKey == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.localSsdCount == INTEGER
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.machineType == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.preemptible == BOOLEAN
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.config.spot == BOOLEAN
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].nodePoolConfig.locations[_] == STRING
    input.Body.placement.managedCluster.config.gkeClusterConfig.nodePoolTarget[_].roles[_] == enum_GkeNodePoolTargetRoles[_]
    input.Body.placement.managedCluster.config.initializationActions[_].executableFile == STRING
    input.Body.placement.managedCluster.config.initializationActions[_].executionTimeout == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.autoDeleteTime == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.autoDeleteTtl == STRING
    input.Body.placement.managedCluster.config.lifecycleConfig.idleDeleteTtl == STRING
    input.Body.placement.managedCluster.config.masterConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.masterConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.masterConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.masterConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.masterConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.masterConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.masterConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.metastoreConfig.dataprocMetastoreService == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.secondaryWorkerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.config.securityConfig.identityConfig.userServiceAccountMapping.STRING == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustAdminServer == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustKdc == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustRealm == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.crossRealmTrustSharedPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.enableKerberos == BOOLEAN
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.kdcDbKeyUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keyPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keystorePasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.keystoreUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.kmsKeyUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.realm == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.rootPrincipalPasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.tgtLifetimeHours == INTEGER
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.truststorePasswordUri == STRING
    input.Body.placement.managedCluster.config.securityConfig.kerberosConfig.truststoreUri == STRING
    input.Body.placement.managedCluster.config.softwareConfig.imageVersion == STRING
    input.Body.placement.managedCluster.config.softwareConfig.optionalComponents[_] == enum_SoftwareConfigOptionalComponents[_]
    input.Body.placement.managedCluster.config.softwareConfig.properties.STRING == STRING
    input.Body.placement.managedCluster.config.tempBucket == STRING
    input.Body.placement.managedCluster.config.workerConfig.accelerators[_].acceleratorCount == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.accelerators[_].acceleratorTypeUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.bootDiskSizeGb == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.bootDiskType == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.localSsdInterface == STRING
    input.Body.placement.managedCluster.config.workerConfig.diskConfig.numLocalSsds == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.imageUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].machineTypes[_] == STRING
    input.Body.placement.managedCluster.config.workerConfig.instanceFlexibilityPolicy.instanceSelectionList[_].rank == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.machineTypeUri == STRING
    input.Body.placement.managedCluster.config.workerConfig.minCpuPlatform == STRING
    input.Body.placement.managedCluster.config.workerConfig.minNumInstances == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.numInstances == INTEGER
    input.Body.placement.managedCluster.config.workerConfig.preemptibility == enum_InstanceGroupConfigPreemptibility[_]
    input.Body.placement.managedCluster.config.workerConfig.startupConfig.requiredRegistrationFraction == NUMBER
    input.Body.placement.managedCluster.labels.STRING == STRING
    input.Body.version == INTEGER
    input.ReqMap.name == STRING
    input.ProviderMetadata.Region == STRING
}