File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
sdks/python/apache_beam/runners/worker Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -134,8 +134,8 @@ def scoped_state(
134134 name_context : Union [str , 'common.NameContext' ],
135135 state_name : str ,
136136 io_target = None ,
137- metrics_container : Optional ['MetricsContainer' ] = None ,
138- suffix : str = '-msecs' ) -> statesampler_impl .ScopedState :
137+ metrics_container : Optional ['MetricsContainer' ] = None
138+ ) -> statesampler_impl .ScopedState :
139139 """Returns a ScopedState object associated to a Step and a State.
140140
141141 Args:
@@ -152,7 +152,7 @@ def scoped_state(
152152 name_context = common .NameContext (name_context )
153153
154154 counter_name = CounterName (
155- state_name + suffix ,
155+ state_name + '-msecs' ,
156156 stage_name = self ._prefix ,
157157 step_name = name_context .metrics_name (),
158158 io_target = io_target )
You can’t perform that action at this time.
0 commit comments