From 593781a7e85cb5d45374a239d21349e37e731e0d Mon Sep 17 00:00:00 2001
From: Egor Kovetskiy <e.kovetskiy@office.ngs.ru>
Date: Fri, 26 Aug 2016 02:23:12 +0700
Subject: [PATCH] compatibility with new runcmd interface

---
 command.go               | 8 +-------
 distributed_lock_node.go | 5 +----
 2 files changed, 2 insertions(+), 11 deletions(-)

diff --git a/command.go b/command.go
index e437e0d..b453ae2 100644
--- a/command.go
+++ b/command.go
@@ -125,13 +125,7 @@ func runRemoteExecutionNode(
 	logLock sync.Locker,
 	outputLock sync.Locker,
 ) (*remoteExecutionNode, error) {
-	remoteCommand, err := node.runner.Command(command)
-	if err != nil {
-		return nil, hierr.Errorf(
-			err,
-			`can't establish remote session`,
-		)
-	}
+	remoteCommand := node.runner.Command(command)
 
 	stdoutBackend := io.Writer(os.Stdout)
 	stderrBackend := io.Writer(os.Stderr)
diff --git a/distributed_lock_node.go b/distributed_lock_node.go
index 05eb031..845aff5 100644
--- a/distributed_lock_node.go
+++ b/distributed_lock_node.go
@@ -56,10 +56,7 @@ func (node *distributedLockNode) lock(
 		node,
 	))
 
-	lockCommand, err := node.runner.Command(lockCommandString)
-	if err != nil {
-		return err
-	}
+	lockCommand := node.runner.Command(lockCommandString)
 
 	stdout, err := lockCommand.StdoutPipe()
 	if err != nil {