def _fetch(self):
    result = self.reader.fetch_watermark_hold(self.state_key)
    for wrapper in result.data:
      for item in wrapper.data:
        for value in item.watermark_holds:
          if (len(value.timestamps) == 1 and
              value.timestamps[0] == MAX_TIMESTAMP):
            # When uninitialized, Windmill returns MAX_TIMESTAMP
            self.hold_time = None
          else:
            for wm_timestamp in value.timestamps:
              timestamp = windmillio.windmill_to_harness_timestamp(
                  wm_timestamp)
              if self.hold_time is None:
                self.hold_time = timestamp
              else:
                self.hold_time = self.output_time_fn_impl.combine(
                    self.hold_time, timestamp)
    self.fetched = True
Given a list of template names, returns the first that can be loaded.
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/worker/windmillstate.py/WindmillWatermarkHoldAccessor._fetch--crossover with--dataset/ETHPy150Open django/django/django/template/engine.py/Engine.select_template