diff --git a/sdks/python/apache_beam/runners/interactive/dataproc/dataproc_cluster_manager.py b/sdks/python/apache_beam/runners/interactive/dataproc/dataproc_cluster_manager.py index 817d4f6b583b..45de5cb7d85b 100644 --- a/sdks/python/apache_beam/runners/interactive/dataproc/dataproc_cluster_manager.py +++ b/sdks/python/apache_beam/runners/interactive/dataproc/dataproc_cluster_manager.py @@ -20,6 +20,7 @@ import logging import re import time +from typing import Any from typing import Optional from apache_beam import version as beam_version @@ -170,7 +171,7 @@ def create_flink_cluster(self) -> None: """Calls _create_cluster with a configuration that enables FlinkRunner.""" init_action_path = self.stage_init_action() # https://cloud.google.com/php/docs/reference/cloud-dataproc/latest/V1.Cluster - cluster = { + cluster: dict[str, Any] = { 'project_id': self.cluster_metadata.project_id, 'cluster_name': self.cluster_metadata.cluster_name, 'config': { diff --git a/sdks/python/pyproject.toml b/sdks/python/pyproject.toml index 5901d817c9c7..fa28734b89c3 100644 --- a/sdks/python/pyproject.toml +++ b/sdks/python/pyproject.toml @@ -212,4 +212,3 @@ invalid-argument = "ignore" invalid-inheritance = "ignore" not-iterable = "ignore" unexpected-keyword = "ignore" -bad-typed-dict-key = "ignore"