

def __init__(self, job):
    'Job is a Job message from the Dataflow API.'
    self._job = job

dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/runners/dataflow_runner.py DataflowPipelineResult.__init__/original