diff --git a/confluent_client/bin/nodeshell b/confluent_client/bin/nodeshell index 8899a013..4621be31 100755 --- a/confluent_client/bin/nodeshell +++ b/confluent_client/bin/nodeshell @@ -46,6 +46,8 @@ def run(): help='Number of commands to run at a time') argparser.add_option('-n', '--nonodeprefix', action='store_true', help='Do not prefix output with node names') + argparser.add_option('-p', '--port', type='int', default=0, + help='Specify a custom port for ssh') argparser.add_option('-m', '--maxnodes', type='int', help='Specify a maximum number of ' 'nodes to run remote ssh command to, ' @@ -59,7 +61,7 @@ def run(): sys.exit(1) client.check_globbing(args[0]) concurrentprocs = options.count - c = client.Command() + c = client.Command() cmdstr = " ".join(args[1:]) currprocs = 0 @@ -79,7 +81,10 @@ def run(): cmd = ex[node]['value'] if not isinstance(cmd, str) and not isinstance(cmd, bytes): cmd = cmd.encode('utf-8') - cmdv = ['ssh', node, cmd] + if options.port: + cmdv = ['ssh', '-p', '{0}'.format(options.port), node, cmd] + else: + cmdv = ['ssh', node, cmd] if currprocs < concurrentprocs: currprocs += 1 run_cmdv(node, cmdv, all, pipedesc) diff --git a/confluent_server/builddeb b/confluent_server/builddeb index 418e6620..47fa7f32 100755 --- a/confluent_server/builddeb +++ b/confluent_server/builddeb @@ -44,6 +44,9 @@ if [ "$OPKGNAME" = "confluent-server" ]; then echo 'confluent_client confluent-client' >> debian/pydist-overrides fi fi +if ! grep wheezy /etc/os-release; then + sed -i 's/^Package: python3-/Package: /' debian/control +fi head -n -1 debian/control > debian/control1 mv debian/control1 debian/control echo 'export PYBUILD_INSTALL_ARGS=--install-lib=/opt/confluent/lib/python' >> debian/rules