Module Import alias Import alias Import alias Import alias Import alias Import alias Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index Str Assign NameStore NameLoad With Call NameLoad SubscriptLoad AttributeLoad NameLoad attr Index Str NameStore body Assign NameStore Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr keyword Str Expr Call AttributeLoad NameLoad attr Str keyword Str keyword NameLoad keyword Str keyword Call AttributeLoad Call AttributeLoad NameLoad attr Str Str Str attr Expr Call AttributeLoad NameLoad attr Str keyword Str keyword Str keyword NameLoad keyword Call AttributeLoad Call AttributeLoad NameLoad attr Str Str Str attr Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body With Call NameLoad Str Str NameStore body Assign NameStore SubscriptLoad NameLoad Index Str For NameStore NameLoad body Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Str Index NameLoad Assign NameStore Call AttributeLoad Str attr NameLoad If CompareNotIn NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr Call AttributeLoad Str attr NameLoad NameLoad Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore ListComp SubscriptLoad SubscriptLoad NameLoad Index Str Index NameLoad comprehension NameStore SubscriptLoad NameLoad Index Str Assign NameStore NameLoad For NameStore NameLoad body If CompareIn NameLoad NameLoad body Assign NameStore NameLoad Break If CompareIsNot NameLoad NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad Str attr SubscriptLoad NameLoad Index Str Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Assign SubscriptStore NameLoad Index Str NameLoad If CompareIn SubscriptLoad SubscriptLoad NameLoad Index Str Index SubscriptLoad NameLoad Index Str NameLoad body TryExcept body Assign NameStore Call AttributeLoad Str attr SubscriptLoad NameLoad Index Str Assign SubscriptStore NameLoad Index Str SubscriptLoad AttributeLoad NameLoad attr Index NameLoad handlers ExceptHandler type NameLoad body Assign NameStore Call AttributeLoad NameLoad attr ListLoad Str Str keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Assign TupleStore NameStore NameStore Call AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str Call AttributeLoad NameLoad attr orelse Assign SubscriptStore NameLoad Index Str SubscriptLoad SubscriptLoad NameLoad Index Str Index SubscriptLoad NameLoad Index Str With Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Str Str Str NameStore body Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr Str
N/A N/A argparse N/A os N/A os.path N/A re N/A subprocess N/A yaml N/A STORM_HOME N/A N/A os environ N/A STORM_HOME N/A stormSetupConfig None N/A N/A open N/A N/A os environ N/A STORM_SETUP_YAML f N/A N/A stormSetupConfig N/A N/A yaml load N/A N/A f read N/A parser N/A N/A argparse ArgumentParser description Configures and runs storm-supervisor N/A N/A N/A parser add_argument --is-storm-supervisor action store_true default False dest is_storm_supervisor help N/A N/A N/A N/A re sub \s+ Supply this flag if this Docker container is running a
    storm-supervisor strip N/A N/A N/A parser add_argument --my-ip-address action append dest my_ip_addresses type str help N/A N/A N/A N/A re sub \s+ IP address for the host machine strip N/A parsedArgs N/A N/A parser parse_args N/A myIpAddresses N/A parsedArgs my_ip_addresses N/A N/A parsedArgs is_storm_supervisor N/A N/A N/A open /etc/dnsmasq-extra-hosts w f N/A N/A stormSupervisorHosts N/A stormSetupConfig N/A storm.supervisor.hosts N/A supervisor_host stormSupervisorHosts N/A N/A ip_address N/A N/A stormSetupConfig N/A servers N/A supervisor_host N/A alias N/A N/A {}-supervisor format supervisor_host N/A N/A ip_address myIpAddresses N/A N/A N/A N/A f write N/A N/A {} {}
 format ip_address alias N/A stormYamlConfig N/A stormSetupConfig N/A storm.yaml N/A storm_yaml_zk_servers_section N/A N/A N/A stormSetupConfig N/A servers N/A zk_server N/A zk_server N/A stormYamlConfig N/A storm.zookeeper.servers N/A zk_server_ip_to_replace None N/A zk_server_ip storm_yaml_zk_servers_section N/A N/A N/A zk_server_ip myIpAddresses N/A N/A zk_server_ip_to_replace zk_server_ip N/A N/A N/A zk_server_ip_to_replace None N/A N/A idx N/A N/A storm_yaml_zk_servers_section index zk_server_ip_to_replace N/A zk_port_env_var N/A N/A ZK_PORT_{}_TCP_ADDR format N/A stormYamlConfig N/A storm.zookeeper.port N/A N/A N/A storm_yaml_zk_servers_section remove zk_server_ip_to_replace N/A N/A N/A storm_yaml_zk_servers_section insert idx N/A N/A os environ N/A zk_port_env_var N/A N/A stormYamlConfig N/A storm.zookeeper.servers storm_yaml_zk_servers_section N/A N/A N/A N/A stormSetupConfig N/A servers N/A N/A stormYamlConfig N/A nimbus.host myIpAddresses N/A N/A N/A N/A nimbusEnvVar N/A N/A NIMBUS_PORT_{}_TCP_ADDR format N/A stormYamlConfig N/A nimbus.thrift.port N/A N/A stormYamlConfig N/A nimbus.host N/A N/A os environ N/A nimbusEnvVar N/A N/A N/A KeyError N/A N/A p N/A N/A subprocess Popen N/A hostname -i stdout N/A subprocess PIPE stderr N/A subprocess PIPE N/A N/A out _ N/A N/A p communicate N/A N/A stormYamlConfig N/A nimbus.host N/A N/A out strip N/A N/A N/A stormYamlConfig N/A nimbus.host N/A N/A stormSetupConfig N/A servers N/A N/A stormYamlConfig N/A nimbus.host N/A N/A open N/A N/A N/A os path join STORM_HOME conf storm.yaml w f N/A N/A N/A N/A f write N/A N/A yaml dump stormYamlConfig default_flow_style False N/A N/A N/A os system supervisord