def _get_unique_step_name(self):
    self._unique_step_id += 1
    return 's%s' % self._unique_step_id
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/runners/dataflow_runner.py/DataflowPipelineRunner._get_unique_step_name/original