def fetch_value(self, state_key):
    request = windmill_pb2.GetDataRequest()
    computation_request = windmill_pb2.ComputationGetDataRequest(
        computation_id=self.computation_id)
    keyed_request = windmill_pb2.KeyedGetDataRequest(
        key=self.key,
        work_token=self.work_token)
    keyed_request.values_to_fetch.add(
        tag=state_key,
        state_family='')
    computation_request.requests.extend([keyed_request])
    request.requests.extend([computation_request])
    return self.windmill.GetData(request)
src, dst -> None
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/worker/windmillstate.py/WindmillStateReader.fetch_value--crossover with--dataset/ETHPy150Open ProgVal/Limnoria/src/utils/file.py/copy