compatibility with new runcmd interface

reconquest · Aug 25, 2016 · 593781a · 593781a
1 parent 4e29b75
commit 593781a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 11 deletions.
diff --git 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
@@ -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 {