Fix error for Regex test

Author: ktalluri456

sdks/python/apache_beam/runners/worker/operations.pxd

@@ -83,7 +83,6 @@ cdef class Operation(object):
   cdef readonly object scoped_start_state
   cdef readonly object scoped_process_state
   cdef readonly object scoped_finish_state
-  cdef readonly object scoped_timer_processing_state
 
   cdef readonly object data_sampler
 
@@ -118,6 +117,7 @@ cdef class DoOperation(Operation):
   cdef dict timer_specs
   cdef public object input_info
   cdef object fn
+  cdef readonly object scoped_timer_processing_state
 
 
 cdef class SdfProcessSizedElements(DoOperation):

sdks/python/apache_beam/runners/worker/operations.py

@@ -49,6 +49,7 @@
 from apache_beam.runners.worker import opcounters
 from apache_beam.runners.worker import operation_specs
 from apache_beam.runners.worker import sideinputs
+from apache_beam.runners.worker import statesampler
 from apache_beam.runners.worker.data_sampler import DataSampler
 from apache_beam.transforms import sideinputs as apache_sideinputs
 from apache_beam.transforms import combiners
@@ -454,6 +455,10 @@ def __init__(
           self.name_context, 'process', metrics_container=self.metrics_container)
       self.scoped_finish_state = self.state_sampler.scoped_state(
           self.name_context, 'finish', metrics_container=self.metrics_container)
+    else:
+      self.scoped_start_state = statesampler.NOOP_SCOPED_STATE
+      self.scoped_process_state = statesampler.NOOP_SCOPED_STATE
+      self.scoped_finish_state = statesampler.NOOP_SCOPED_STATE
     # TODO(ccy): the '-abort' state can be added when the abort is supported in
     # Operations.
     self.receivers = []  # type: List[ConsumerSet]

sdks/python/apache_beam/runners/worker/statesampler.py

@@ -171,3 +171,15 @@ def commit_counters(self) -> None:
     for state in self._states_by_name.values():
       state_msecs = int(1e-6 * state.nsecs)
       state.counter.update(state_msecs - state.counter.value())
+
+class NoOpScopedState:
+  def __enter__(self):
+    pass
+  
+  def __exit__(self, exc_type, exc_val, exc_tb):
+    pass
+
+  def sampled_msecs_int(self):
+    return 0
+  
+NOOP_SCOPED_STATE = NoOpScopedState()