Skip to content

Commit bbcf1b9

Browse files
committed
support clowder2 job_id field
1 parent 6780c28 commit bbcf1b9

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

pyclowder/connectors.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -723,10 +723,12 @@ def on_message(self, channel, method, header, body):
723723
if 'routing_key' not in json_body and method.routing_key:
724724
json_body['routing_key'] = method.routing_key
725725

726-
if 'jobid' not in json_body:
727-
job_id = None
728-
else:
726+
if 'jobid' in json_body:
729727
job_id = json_body['jobid']
728+
elif 'job_id' in json_body:
729+
job_id = json_body['job_id']
730+
else:
731+
job_id = None
730732

731733
self.worker = RabbitMQHandler(self.extractor_name, self.extractor_info, job_id, self.check_message,
732734
self.process_message, self.ssl_verify, self.mounted_paths, self.clowder_url,

0 commit comments

Comments
 (0)