summaryrefslogtreecommitdiff
path: root/pkg/pipe/pipe_factory.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-01-19 18:10:39 +0300
committerGitHub <[email protected]>2021-01-19 18:10:39 +0300
commit0ff05b2732b4fd0783f959c94c54d7e39169f979 (patch)
treef50aa894ea4e5b402332f7f4a13b8c50ebb09126 /pkg/pipe/pipe_factory.go
parent75ebbaac89ce8ebc3ab8de47b16e137844cfcd8a (diff)
parentd8e42927b63a0b102ce10d465a10d64bb6c02e22 (diff)
Merge pull request #487 from spiral/refactor/server_log_messagesv2.0.0-beta9
refactor(errors, logs): Uniform all errors operations, Update server log level of the server log messages
Diffstat (limited to 'pkg/pipe/pipe_factory.go')
-rwxr-xr-xpkg/pipe/pipe_factory.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/pkg/pipe/pipe_factory.go b/pkg/pipe/pipe_factory.go
index c36c13e2..b656eff8 100755
--- a/pkg/pipe/pipe_factory.go
+++ b/pkg/pipe/pipe_factory.go
@@ -32,7 +32,7 @@ type SpawnResult struct {
// method Wait() must be handled on level above.
func (f *Factory) SpawnWorkerWithTimeout(ctx context.Context, cmd *exec.Cmd, listeners ...events.Listener) (worker.BaseProcess, error) {
c := make(chan SpawnResult)
- const op = errors.Op("spawn worker with context")
+ const op = errors.Op("factory_spawn_worker_with_timeout")
go func() {
w, err := workerImpl.InitBaseWorker(cmd, workerImpl.AddListeners(listeners...))
if err != nil {
@@ -114,7 +114,7 @@ func (f *Factory) SpawnWorkerWithTimeout(ctx context.Context, cmd *exec.Cmd, lis
}
func (f *Factory) SpawnWorker(cmd *exec.Cmd, listeners ...events.Listener) (worker.BaseProcess, error) {
- const op = errors.Op("spawn worker")
+ const op = errors.Op("factory_spawn_worker")
w, err := workerImpl.InitBaseWorker(cmd, workerImpl.AddListeners(listeners...))
if err != nil {
return nil, errors.E(op, err)