`pipeline.RunConcurrent` has lots of problems with graceful termination because of race conditions.
pipeline.RunConcurrenthas lots of problems with graceful termination because of race conditions.