

def __init__(self, cache=None, blocking=False):
    self._cache = (cache if (cache is not None) else PValueCache())
    self.blocking = cache
    self.result = None
    self._unique_step_id = 0

dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/runners/dataflow_runner.py DataflowPipelineRunner.__init__/VarMisuse@41/46 `blocking`->`cache`