Module Expr Str ImportFrom alias alias alias Import alias Import alias Import alias Import alias identifier ImportFrom alias ImportFrom alias alias ImportFrom alias ImportFrom alias ImportFrom alias alias alias alias alias alias alias ImportFrom alias alias alias alias alias alias alias alias alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias Assign NameStore Num FunctionDef arguments args defaults body Expr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr Num Call AttributeLoad NameLoad attr TryExcept body Import alias identifier handlers ExceptHandler type NameLoad body Assign NameStore NameLoad TryExcept body Import alias identifier handlers ExceptHandler type NameLoad body Assign NameStore NameLoad Return TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call NameLoad NameLoad Assign NameStore UnaryOpNot Call NameLoad GeneratorExp CompareEq AttributeLoad NameLoad attr NameLoad comprehension NameStore NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body If BoolOpAnd NameLoad UnaryOpNot Call NameLoad NameLoad NameLoad body Expr Call NameLoad Call AttributeLoad Str attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call NameLoad NameLoad NameLoad keyword NameLoad While UnaryOpNot Call NameLoad NameLoad NameLoad body Expr Call NameLoad Call AttributeLoad Str attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr Num Expr Call NameLoad Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad body Assign NameStore Dict Str Str Str NameLoad NameLoad NameLoad If Call AttributeLoad NameLoad attr Str NameLoad body Assign NameStore Call AttributeLoad Str attr ListLoad SubscriptLoad NameLoad Index Str NameLoad Str Str Assign SubscriptStore NameLoad Index Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str Dict Assign NameStore BoolOpOr Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr Str Assign NameStore BoolOpOr Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr Str Expr Call NameLoad Call AttributeLoad Str attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr If NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad If NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad If Call NameLoad Call AttributeLoad NameLoad attr Str NameLoad body Assign SubscriptStore NameLoad Index Str SubscriptLoad NameLoad Index Str If Call NameLoad Call AttributeLoad NameLoad attr Str NameLoad body Assign SubscriptStore NameLoad Index Str SubscriptLoad NameLoad Index Str If Call NameLoad Call AttributeLoad NameLoad attr Str NameLoad body Assign SubscriptStore NameLoad Index Str Call AttributeLoad SubscriptLoad NameLoad Index Str attr If CompareIsNot NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr Str NameLoad If CompareIsNot NameLoad NameLoad body For NameStore Call NameLoad AttributeLoad NameLoad attr body Assign NameStore AttributeLoad AttributeLoad NameLoad attr attr If CompareIsNot NameLoad NameLoad body Assign AttributeStore NameLoad attr Call AttributeLoad Str attr NameLoad AttributeLoad NameLoad attr For NameStore Call NameLoad AttributeLoad NameLoad attr body Assign NameStore AttributeLoad AttributeLoad NameLoad attr attr If CompareIsNot NameLoad NameLoad body Assign AttributeStore NameLoad attr Call AttributeLoad Str attr NameLoad AttributeLoad NameLoad attr Expr Call NameLoad Call AttributeLoad Str attr NameLoad keyword Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad keyword Call AttributeLoad NameLoad attr NameLoad keyword AttributeLoad NameLoad attr Expr Call NameLoad Str decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign TupleStore NameStore NameStore Call NameLoad Assign NameStore Call NameLoad NameLoad Str NameLoad If Call NameLoad NameLoad body Expr Call NameLoad NameLoad NameLoad NameLoad Assign NameStore Call NameLoad NameLoad Str NameLoad If Call NameLoad NameLoad body Expr Call NameLoad NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign TupleStore NameStore NameStore Call NameLoad Assign NameStore Call NameLoad NameLoad Str NameLoad If Call NameLoad NameLoad body Expr Call NameLoad NameLoad NameLoad NameLoad Assign NameStore Call NameLoad NameLoad Str NameLoad If Call NameLoad NameLoad body Expr Call NameLoad NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr Expr Call NameLoad Call AttributeLoad Str attr NameLoad NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore Num With Call NameLoad NameLoad Str NameStore body While NameLoad body Expr Call NameLoad Call AttributeLoad Str attr NameLoad NameLoad keyword Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad If UnaryOpNot NameLoad body Break Expr Call AttributeLoad NameLoad attr NameLoad NameLoad AugAssignAdd NameStore Call NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call NameLoad Call AttributeLoad Str attr NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad Str Num Num NameLoad NameLoad NameLoad NameLoad NameLoad body Expr Str Assign NameStore Call NameLoad Assign TupleStore NameStore NameStore Call NameLoad NameLoad Assign TupleStore NameStore NameStore Call NameLoad NameLoad Assign NameStore Call NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str NameLoad Expr Call NameLoad NameLoad Expr Call NameLoad NameLoad NameLoad NameLoad If NameLoad body Assign SubscriptStore NameLoad Index Str Call AttributeLoad SubscriptLoad NameLoad Index Str attr Str Expr Call NameLoad NameLoad NameLoad Call AttributeLoad Str attr SubscriptLoad NameLoad Index Str NameLoad keyword Call AttributeLoad NameLoad attr Str Assign NameStore Call AttributeLoad Str attr ListLoad AttributeLoad NameLoad attr NameLoad Str Str For NameStore Call NameLoad AttributeLoad NameLoad attr body Assign NameStore AttributeLoad AttributeLoad NameLoad attr attr If Call NameLoad NameLoad NameLoad body If CompareIn Str AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr NameLoad For NameStore Call NameLoad AttributeLoad NameLoad attr body Assign NameStore AttributeLoad AttributeLoad NameLoad attr attr If Call NameLoad NameLoad NameLoad body If CompareIn Str AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr NameLoad If NameLoad body Assign NameStore UnaryOpNot Call NameLoad GeneratorExp Call NameLoad NameLoad NameLoad comprehension NameStore AttributeLoad NameLoad attr Assign NameStore Call NameLoad keyword NameLoad Expr Call NameLoad Call AttributeLoad Str attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr With Call NameLoad NameLoad TupleStore NameStore NameStore body Assign NameStore Call NameLoad NameLoad keyword NameLoad keyword NameLoad Expr Call NameLoad NameLoad NameLoad NameLoad NameLoad Assign NameStore Call NameLoad NameLoad NameLoad Expr Call NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad keyword NameLoad keyword NameLoad Expr Call NameLoad NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr Str keyword NameLoad keyword AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr keyword NameLoad Expr Call NameLoad NameLoad Expr Call NameLoad NameLoad Expr Call NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Str Str keyword Str keyword Str Expr Call NameLoad NameLoad Expr Call NameLoad NameLoad Expr Call NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Str Str keyword Str keyword Str keyword Str Expr Call NameLoad NameLoad Expr Call NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call NameLoad NameLoad Expr Call NameLoad keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr decorator_list
N/A N/A 
Submit a Storm topology to Nimbus.
 __future__ absolute_import print_function unicode_literals N/A os N/A sys N/A time N/A simplejson json fabric.api env six itervalues string_types dsl.component JavaComponentSpec thrift storm_thrift util activate_env get_config get_env_config get_nimbus_client get_topology_definition get_topology_from_file ssh_tunnel common add_ackers add_debug add_environment add_name add_options add_par add_wait add_workers resolve_ackers_workers jar jar_for_deploy kill _kill_topology list _list_topologies update_virtualenv create_or_update_virtualenvs storm_thrift ShellComponent N/A THRIFT_CHUNK_SIZE 307200 get_user_tasks N/A N/A N/A N/A N/A Get tasks defined in a user's tasks.py and fabric.py file which is
    assumed to be in the current working directory.

    :returns: a `tuple` (invoke_tasks, fabric_tasks)
     N/A N/A N/A N/A sys path insert 0 N/A N/A os getcwd N/A N/A N/A tasks user_invoke N/A N/A N/A ImportError N/A N/A user_invoke None N/A N/A N/A fabfile user_fabric N/A N/A N/A ImportError N/A N/A user_fabric None N/A N/A user_invoke user_fabric N/A is_safe_to_submit N/A N/A topology_name nimbus_client N/A N/A N/A Is topology not in list of current topologies? N/A topologies N/A _list_topologies nimbus_client N/A safe N/A N/A any N/A N/A N/A topology name topology_name N/A topology topologies N/A safe N/A _kill_existing_topology N/A N/A topology_name force wait nimbus_client N/A N/A N/A N/A force N/A N/A is_safe_to_submit topology_name nimbus_client N/A N/A N/A print N/A N/A Killing current "{}" topology. format topology_name N/A N/A N/A N/A sys stdout flush N/A N/A _kill_topology topology_name nimbus_client wait wait N/A N/A N/A is_safe_to_submit topology_name nimbus_client N/A N/A N/A print N/A N/A Waiting for topology {} to quit... format topology_name N/A N/A N/A N/A sys stdout flush N/A N/A N/A time sleep 0.5 N/A N/A print Killed. N/A N/A N/A N/A sys stdout flush N/A _submit_topology N/A N/A topology_name topology_class uploaded_jar config env_config workers ackers nimbus_client options debug N/A None False N/A N/A storm_options N/A topology.workers topology.acker.executors topology.debug workers ackers debug N/A N/A N/A env_config get use_virtualenv True N/A N/A python_path N/A N/A / join N/A N/A env_config N/A virtualenv_root topology_name bin python N/A N/A storm_options N/A topology.python.path python_path N/A log_config N/A N/A env_config get log N/A N/A log_path N/A N/A N/A log_config get path N/A N/A env_config get log_path N/A log_file N/A N/A N/A log_config get file N/A N/A env_config get log_file N/A N/A print N/A N/A Routing Python logging to {}. format log_path N/A N/A N/A N/A sys stdout flush N/A log_path N/A N/A N/A storm_options N/A pystorm.log.path log_path N/A log_file N/A N/A N/A storm_options N/A pystorm.log.file log_file N/A N/A isinstance N/A N/A log_config get max_bytes int N/A N/A N/A storm_options N/A pystorm.log.max_bytes N/A log_config N/A max_bytes N/A N/A isinstance N/A N/A log_config get backup_count int N/A N/A N/A storm_options N/A pystorm.log.backup_count N/A log_config N/A backup_count N/A N/A isinstance N/A N/A log_config get level string_types N/A N/A N/A storm_options N/A pystorm.log.level N/A N/A N/A log_config N/A level lower N/A N/A options None N/A N/A N/A N/A storm_options update options N/A serializer N/A N/A env_config get serializer N/A N/A config get serializer None N/A N/A serializer None N/A N/A thrift_bolt N/A itervalues N/A topology_class thrift_bolts N/A N/A inner_shell N/A N/A thrift_bolt bolt_object shell N/A N/A inner_shell None N/A N/A N/A inner_shell script N/A N/A -s {} {} format serializer N/A inner_shell script N/A thrift_spout N/A itervalues N/A topology_class thrift_spouts N/A N/A inner_shell N/A N/A thrift_spout spout_object shell N/A N/A inner_shell None N/A N/A N/A inner_shell script N/A N/A -s {} {} format serializer N/A inner_shell script N/A N/A print N/A N/A Submitting {} topology to nimbus... format topology_name end N/A N/A N/A N/A sys stdout flush N/A N/A N/A nimbus_client submitTopology name topology_name uploadedJarLocation uploaded_jar jsonConf N/A N/A json dumps storm_options topology N/A topology_class thrift_topology N/A N/A print done N/A _pre_submit_hooks N/A N/A topology_name env_name env_config N/A N/A N/A Pre-submit hooks for invoke and fabric. N/A N/A user_invoke user_fabric N/A get_user_tasks N/A pre_submit_invoke N/A getattr user_invoke pre_submit None N/A N/A callable pre_submit_invoke N/A N/A N/A pre_submit_invoke topology_name env_name env_config N/A pre_submit_fabric N/A getattr user_fabric pre_submit None N/A N/A callable pre_submit_fabric N/A N/A N/A pre_submit_fabric topology_name env_name env_config N/A _post_submit_hooks N/A N/A topology_name env_name env_config N/A N/A N/A Post-submit hooks for invoke and fabric. N/A N/A user_invoke user_fabric N/A get_user_tasks N/A post_submit_invoke N/A getattr user_invoke post_submit None N/A N/A callable post_submit_invoke N/A N/A N/A post_submit_invoke topology_name env_name env_config N/A post_submit_fabric N/A getattr user_fabric post_submit None N/A N/A callable post_submit_fabric N/A N/A N/A post_submit_fabric topology_name env_name env_config N/A _upload_jar N/A N/A nimbus_client local_path N/A N/A N/A upload_location N/A N/A nimbus_client beginFileUpload N/A N/A print N/A N/A Uploading topology jar {} to assigned location: {} format local_path upload_location N/A total_bytes N/A N/A N/A os path getsize local_path N/A bytes_uploaded 0 N/A N/A open local_path rb local_jar N/A N/A True N/A N/A N/A print N/A N/A Uploaded {}/{} bytes format bytes_uploaded total_bytes end N/A N/A N/A N/A sys stdout flush N/A curr_chunk N/A N/A local_jar read THRIFT_CHUNK_SIZE N/A N/A curr_chunk N/A N/A N/A N/A N/A nimbus_client uploadChunk upload_location curr_chunk N/A bytes_uploaded N/A len curr_chunk N/A N/A N/A nimbus_client finishFileUpload upload_location N/A N/A print N/A N/A Uploaded {}/{} bytes format bytes_uploaded total_bytes N/A N/A N/A N/A sys stdout flush N/A upload_location N/A submit_topology N/A N/A name env_name workers ackers options force debug wait simple_jar N/A None prod 2 2 None False False None True N/A N/A Submit a topology to a remote Storm cluster. N/A config N/A get_config N/A N/A name topology_file N/A get_topology_definition name N/A N/A env_name env_config N/A get_env_config env_name N/A topology_class N/A get_topology_from_file topology_file N/A use_venv N/A N/A env_config get use_virtualenv True N/A N/A activate_env env_name N/A N/A _pre_submit_hooks name env_name env_config N/A use_venv N/A N/A N/A config N/A virtualenv_specs N/A N/A N/A config N/A virtualenv_specs rstrip / N/A N/A create_or_update_virtualenvs env_name name N/A N/A {}/{}.txt format N/A config N/A virtualenv_specs name virtualenv_flags N/A N/A env_config get virtualenv_flags N/A streamparse_run_path N/A N/A / join N/A N/A env virtualenv_root name bin streamparse_run N/A thrift_bolt N/A itervalues N/A topology_class thrift_bolts N/A N/A inner_shell N/A N/A thrift_bolt bolt_object shell N/A N/A isinstance inner_shell ShellComponent N/A N/A N/A streamparse_run N/A inner_shell execution_command N/A N/A N/A inner_shell execution_command streamparse_run_path N/A thrift_spout N/A itervalues N/A topology_class thrift_spouts N/A N/A inner_shell N/A N/A thrift_spout spout_object shell N/A N/A isinstance inner_shell ShellComponent N/A N/A N/A streamparse_run N/A inner_shell execution_command N/A N/A N/A inner_shell execution_command streamparse_run_path N/A simple_jar N/A N/A simple_jar N/A N/A any N/A N/A isinstance spec JavaComponentSpec N/A spec N/A topology_class specs N/A topology_jar N/A jar_for_deploy simple_jar simple_jar N/A N/A print N/A N/A Deploying "{}" topology... format name N/A N/A N/A N/A sys stdout flush N/A N/A ssh_tunnel env_config N/A host port N/A N/A nimbus_client N/A get_nimbus_client env_config host host port port N/A N/A _kill_existing_topology name force wait nimbus_client N/A uploaded_jar N/A _upload_jar nimbus_client topology_jar N/A N/A _submit_topology name topology_class uploaded_jar config env_config workers ackers nimbus_client options options debug debug N/A N/A _post_submit_hooks name env_name env_config N/A subparser_hook N/A N/A subparsers N/A N/A N/A  Hook to add subparser for this command.  N/A subparser N/A N/A subparsers add_parser submit description __doc__ help N/A main __doc__ N/A N/A N/A subparser set_defaults func main N/A N/A add_ackers subparser N/A N/A add_debug subparser N/A N/A add_environment subparser N/A N/A N/A subparser add_argument -f --force action store_true help Force a topology to submit by killing any currently running topologies with the same name. N/A N/A add_name subparser N/A N/A add_options subparser N/A N/A add_par subparser N/A N/A N/A subparser add_argument -u --uber_jar help Build an Uber-JAR even if you have no Java components in your topology.  Useful if you are providing your own seriailzer class. dest simple_jar action store_false N/A N/A add_wait subparser N/A N/A add_workers subparser N/A main N/A N/A args N/A N/A N/A  Submit a Storm topology to Nimbus.  N/A N/A resolve_ackers_workers args N/A N/A submit_topology name N/A args name env_name N/A args environment workers N/A args workers ackers N/A args ackers options N/A args options force N/A args force debug N/A args debug wait N/A args wait simple_jar N/A args simple_jar N/A