File tree Expand file tree Collapse file tree 2 files changed +0
-4
lines changed
Expand file tree Collapse file tree 2 files changed +0
-4
lines changed Original file line number Diff line number Diff line change @@ -524,7 +524,6 @@ def register_extractor(self, endpoints):
524524 else :
525525 logger .info ("Unable to register extractor without an API key." )
526526 return
527- #url += "?user=%s" % self.clowder_email # TODO: This will not work, need an auth key matching email
528527 try :
529528 result = requests .post (url .strip (), headers = headers ,
530529 data = json .dumps (data ),
@@ -845,8 +844,6 @@ def send_heartbeat(self):
845844 try :
846845 self .channel .connection .process_data_events ()
847846 if time .time () >= next_heartbeat :
848- logging .getLogger (__name__ ).info ("Sending heartbeat..." )
849- logging .getLogger (__name__ ).info (message )
850847 self .channel .basic_publish (exchange = 'extractors' , routing_key = '' , body = json .dumps (message ))
851848 next_heartbeat = time .time () + self .heartbeat
852849 except SystemExit :
Original file line number Diff line number Diff line change @@ -179,7 +179,6 @@ def start(self):
179179 connector .connect ()
180180 connector .register_extractor (self .args .registration_endpoints )
181181
182- # TODO: register extractor initially without _process_message?
183182 url = "%sapi/extractors" % self .args .clowder_url
184183 if url not in connector .registered_clowder :
185184 connector .register_extractor ("%s" % (url ))
You can’t perform that action at this time.
0 commit comments