def METHOD_NAME(self) -> None:
    transform_result = (
        self.pipeline
        | beam.Create(['item', 'item', 'item'])
        | job_result_transforms.CountObjectsToJobRunResult('PREFIX')
    )
    self.assert_pcoll_equal(
        transform_result,
        [job_run_result.JobRunResult.as_stdout('PREFIX SUCCESS: 3')]
    )