

def _get_cloud_encoding(self, coder):
    'Returns an encoding based on a coder object.'
    if (not isinstance(coder, coders.Coder)):
        raise TypeError(('Coder object must inherit from coders.Coder: %s.' % str(coder)))
    return coder.as_cloud_object()

dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/runners/dataflow_runner.py DataflowPipelineRunner._get_cloud_encoding/original