def METHOD_NAME(self) -> None:
    transform_result = (
        self.pipeline
        | beam.Create([
                result.Err('err 1'),
                result.Err('err 2'),
                result.Err('err 2')
            ])
        | job_result_transforms.ResultsToJobRunResults()
    )
    self.assert_pcoll_equal(
        transform_result,
        [
            job_run_result.JobRunResult.as_stderr('ERROR: "err 1": 1'),
            job_run_result.JobRunResult.as_stderr('ERROR: "err 2": 2')
        ]
    )