Skip to content

Commit 3226a1c

Browse files
author
Nathan Marz
committed
print usage if no arguments given to storm script
1 parent 2e41051 commit 3226a1c

File tree

1 file changed

+22
-4
lines changed

1 file changed

+22
-4
lines changed

bin/storm

+22-4
Original file line numberDiff line numberDiff line change
@@ -60,9 +60,6 @@ def exec_storm_class(klass, jvmtype="-server", childopts="", extrajars=[], args=
6060
print "Running: " + command
6161
os.system(command)
6262

63-
COMMAND = sys.argv[1]
64-
ARGS = sys.argv[2:]
65-
6663
def jar(jarfile, klass, *args):
6764
exec_storm_class(
6865
klass,
@@ -105,4 +102,25 @@ def print_classpath():
105102

106103
COMMANDS = {"jar": jar, "kill": kill, "shell": shell, "nimbus": nimbus, "ui": ui, "supervisor": supervisor, "localconfvalue": print_localconfvalue, "remoteconfvalue": print_remoteconfvalue, "repl": repl, "classpath": print_classpath}
107104

108-
COMMANDS[COMMAND](*ARGS)
105+
def print_commands():
106+
global COMMANDS
107+
cmds = COMMANDS.keys()
108+
cmds.sort()
109+
print "Commands:\n\t", reduce(lambda x,y: x + ', ' + y, cmds[1:], cmds[0])
110+
111+
def print_usage(msg=None):
112+
if msg != None:
113+
print msg
114+
print_commands()
115+
116+
def main():
117+
if len(sys.argv) <= 1:
118+
print_usage()
119+
sys.exit(-1)
120+
121+
COMMAND = sys.argv[1]
122+
ARGS = sys.argv[2:]
123+
COMMANDS[COMMAND](*ARGS)
124+
125+
if __name__ == "__main__":
126+
main()

0 commit comments

Comments
 (0)