(subparsers)
| 431 | |
| 432 | |
| 433 | def initialize_jar_subcommand(subparsers): |
| 434 | jar_help = """Runs the main method of class with the specified arguments. |
| 435 | The storm worker dependencies and configs in ~/.storm are put on the classpath. |
| 436 | The process is configured so that StormSubmitter |
| 437 | (https://storm.apache.org/releases/current/javadocs/org/apache/storm/StormSubmitter.html) |
| 438 | will upload the jar at topology-jar-path when the topology is submitted. |
| 439 | |
| 440 | When you pass jars and/or artifacts options, StormSubmitter will upload them when the topology is submitted, and they will be included to classpath of both the process which runs the class, and also workers for that topology. |
| 441 | """ |
| 442 | jar_parser = subparsers.add_parser("jar", help=jar_help, formatter_class=SortingHelpFormatter) |
| 443 | |
| 444 | add_topology_jar_options(jar_parser) |
| 445 | add_client_jar_options(jar_parser) |
| 446 | |
| 447 | jar_parser.add_argument( |
| 448 | "--storm-server-classpath", |
| 449 | action='store_true', |
| 450 | help=''' |
| 451 | If for some reason you need to have the full storm classpath, |
| 452 | not just the one for the worker you may include the command line option `--storm-server-classpath`. |
| 453 | Please be careful because this will add things to the classpath |
| 454 | that will not be on the worker classpath |
| 455 | and could result in the worker not running.''' |
| 456 | ) |
| 457 | |
| 458 | jar_parser.set_defaults(func=jar) |
| 459 | add_common_options(jar_parser) |
| 460 | |
| 461 | |
| 462 | def initialize_local_subcommand(subparsers): |
no test coverage detected