()
| 191 | } |
| 192 | |
| 193 | func (b *Bridge) startPipelineAsync() { |
| 194 | go func() { |
| 195 | if err := b.startPipeline(); err != nil && b.ctx.Err() == nil { |
| 196 | log.Errorf("[bridge] failed to restart pipeline %s: %v", b.cfg.PipelineName, err) |
| 197 | } |
| 198 | }() |
| 199 | } |
| 200 | |
| 201 | func (b *Bridge) openJobStream() error { |
| 202 | stream, err := b.rpc.JobStream(b.listenerContext()) |
no test coverage detected