27
27
import tensorflow .compat .v2 as tf
28
28
29
29
30
+ _OLD = 'interleave_parallel_reads'
31
+ _NEW = 'interleave_cycle_length'
32
+ _WARNING_MSG = (
33
+ '`{}` argument of `tfds.ReadConfig` is '
34
+ 'deprecated and will be removed in a future version. Please use '
35
+ '`{}` instead.' ).format (_OLD , _NEW )
36
+
37
+
30
38
# TODO(tfds): Use dataclasses once Py2 support is dropped
31
39
@attr .s
32
40
class _ReadConfig (object ):
@@ -45,6 +53,16 @@ class _ReadConfig(object):
45
53
interleave_block_length = attr .ib (default = 16 )
46
54
experimental_interleave_sort_fn = attr .ib (default = None )
47
55
56
+ @property
57
+ def interleave_parallel_reads (self ):
58
+ logging .warning (_WARNING_MSG )
59
+ return self .interleave_cycle_length
60
+
61
+ @interleave_parallel_reads .setter
62
+ def interleave_parallel_reads (self , value ):
63
+ logging .warning (_WARNING_MSG )
64
+ self .interleave_cycle_length = value
65
+
48
66
49
67
class ReadConfig (_ReadConfig ):
50
68
"""Configures input reading pipeline.
@@ -74,14 +92,9 @@ class ReadConfig(_ReadConfig):
74
92
"""
75
93
76
94
def __init__ (self , ** kwargs ):
77
- old = 'interleave_parallel_reads'
78
- new = 'interleave_cycle_length'
79
- if old in kwargs :
80
- if new in kwargs :
81
- raise ValueError ('Cannot set both {} and {}' .format (old , new ))
82
- logging .warning (
83
- '`%s` argument of `tfds.ReadConfig` is '
84
- 'deprecated and will be removed in a future version. Please use '
85
- '`%s` instead.' , old , new )
86
- kwargs [old ] = kwargs .pop (new )
95
+ if _OLD in kwargs :
96
+ if _NEW in kwargs :
97
+ raise ValueError ('Cannot set both {} and {}' .format (_OLD , _NEW ))
98
+ logging .warning (_WARNING_MSG )
99
+ kwargs [_OLD ] = kwargs .pop (_NEW )
87
100
super (ReadConfig , self ).__init__ (** kwargs )
0 commit comments