@@ -83,7 +83,7 @@ def __init__(self):
8383 self .parser .add_argument ('--pickle' , type = file , nargs = '*' , dest = "hpc_picklefile" ,
8484 default = None , action = 'append' ,
8585 help = 'pickle file that needs to be processed (only needed for HPC)' )
86- self .parser .add_argument ('--register' , '-r' , nargs = '?' , dest = "regstration_endpoints " ,
86+ self .parser .add_argument ('--register' , '-r' , nargs = '?' , dest = "registration_endpoints " ,
8787 default = registration_endpoints ,
8888 help = 'Clowder registration URL (default=%s)' % registration_endpoints )
8989 self .parser .add_argument ('--rabbitmqURI' , nargs = '?' , dest = 'rabbitmq_uri' , default = rabbitmq_uri ,
@@ -158,7 +158,7 @@ def start(self):
158158 rabbitmq_key = rabbitmq_key ,
159159 mounted_paths = json .loads (self .args .mounted_paths ))
160160 rconn .connect ()
161- rconn .register_extractor (self .args .regstration_endpoints )
161+ rconn .register_extractor (self .args .registration_endpoints )
162162 connectors .append (rconn )
163163 threading .Thread (target = rconn .listen , name = "Connector-" + str (connum )).start ()
164164 elif self .args .connector == "HPC" :
@@ -171,7 +171,7 @@ def start(self):
171171 process_message = self .process_message ,
172172 picklefile = self .args .hpc_picklefile ,
173173 mounted_paths = json .loads (self .args .mounted_paths ))
174- hconn .register_extractor (self .args .regstration_endpoints )
174+ hconn .register_extractor (self .args .registration_endpoints )
175175 connectors .append (hconn )
176176 threading .Thread (target = hconn .listen , name = "Connector-" + str (connum )).start ()
177177 elif self .args .connector == "Local" :
0 commit comments