commit facd7e7081c4849577c91255ce4d5b1c5d5a9614
author Xiaoyao Qian <qian13@illinois.edu> Wed Apr 10 11:29:16 2019 -0700
committer Neng Lu <freeneng@gmail.com> Wed Apr 10 11:29:16 2019 -0700
tree c89b9b51dc5f18d47f7beb9796ee228581c8d93f
parent 6f4eee97ba93c80c1de68132b721fc51aa3e4c43

Fix heron-shell command invocation (#3236)

heron/executor/src/python/heron_executor.py

diff --git a/heron/executor/src/python/heron_executor.py b/heron/executor/src/python/heron_executor.py
index e727fdd..0c8f21c 100755
--- a/heron/executor/src/python/heron_executor.py
+++ b/heron/executor/src/python/heron_executor.py
@@ -1033,11 +1033,11 @@
       return {}
     if self._get_instance_plans(self.packing_plan, self.shard) is None and self.shard != 0:
       retval = {}
-      retval['heron-shell'] = [
+      retval['heron-shell'] = Command([
           '%s' % self.heron_shell_binary,
           '--port=%s' % self.shell_port,
           '--log_file_prefix=%s/heron-shell-%s.log' % (self.log_dir, self.shard),
-          '--secret=%s' % self.topology_id]
+          '--secret=%s' % self.topology_id], self.shell_env)
       return retval
 
     if self.shard == 0: