diff --git a/lib/ncbo_cron/ontology_submission_parser.rb b/lib/ncbo_cron/ontology_submission_parser.rb index f493eced..8d33f89d 100644 --- a/lib/ncbo_cron/ontology_submission_parser.rb +++ b/lib/ncbo_cron/ontology_submission_parser.rb @@ -29,6 +29,8 @@ def process_queue_submissions(options={}) redis.hdel(QUEUE_HOLDER, key) # if :remote_pull is one of the actions, pull the ontology and halt if no new submission is found + # if a new submission is found, replace the submission ID with the new one and proceed with + # processing the remaining actions on the new submission if actions.key?(:remote_pull) && actions[:remote_pull] acronym = NcboCron::Helpers::OntologyHelper.acronym_from_submission_id(realKey) new_submission = NcboCron::Helpers::OntologyHelper.do_ontology_pull(acronym, enable_pull_umls: false,