Skip to content

Commit b5ae891

Browse files
zoyahavtfx-copybara
authored andcommitted
Remove typehints causing beam typehint warnings
PiperOrigin-RevId: 510146806
1 parent 935fcf0 commit b5ae891

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

tensorflow_transform/beam/analyzer_cache.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -307,9 +307,9 @@ def _write_cache(self, manifest_file, dataset_key_index, dataset_key_dir,
307307
manifest_file.write(manifest)
308308
return cache_is_written
309309

310-
def expand(
311-
self, dataset_cache_dict: Dict[DatasetKey, DatasetCache]
312-
) -> List[beam.pvalue.PDone]:
310+
# TODO(b/269419184): Add typehints when possible:
311+
# expand(self, dataset_cache_dict: Dict[DatasetKey, DatasetCache]) -> List[beam.pvalue.PDone] # pylint: disable=line-too-long
312+
def expand(self, dataset_cache_dict):
313313
if self._sorted_dataset_keys is None:
314314
sorted_dataset_keys_list = sorted(dataset_cache_dict.keys())
315315
else:
@@ -369,7 +369,9 @@ def _should_read_cache_entry_key(self, key: str) -> bool:
369369
return (self._filtered_cache_entry_keys is None or
370370
key in self._filtered_cache_entry_keys)
371371

372-
def expand(self, pipeline: beam.Pipeline) -> Dict[DatasetKey, DatasetCache]:
372+
# TODO(b/269419184): Add typehints when possible:
373+
# expand(self, pipeline: beam.Pipeline) -> Dict[DatasetKey, DatasetCache]
374+
def expand(self, pipeline: beam.Pipeline):
373375
result = {}
374376

375377
for dataset_key_idx, dataset_key in enumerate(self._sorted_dataset_keys):

0 commit comments

Comments
 (0)