Skip to content

Commit 6e762ad

Browse files
committed
Allow older versions of Clowder to use newer pyClowder
1 parent 80e3e13 commit 6e762ad

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

pyclowder/connectors.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -760,7 +760,10 @@ def on_message(self, channel, method, header, body):
760760
if 'routing_key' not in json_body and method.routing_key:
761761
json_body['routing_key'] = method.routing_key
762762

763-
job_id = json_body['jobid']
763+
if 'jobid' not in json_body:
764+
job_id = None
765+
else:
766+
job_id = json_body['jobid']
764767

765768
self.worker = RabbitMQHandler(self.extractor_name, self.extractor_info, job_id, self.check_message,
766769
self.process_message, self.ssl_verify, self.mounted_paths,

0 commit comments

Comments
 (0)