tlpipe.timestream.barrier.Barrier.prefix

Barrier.prefix = 'br_'