Skip to content
Snippets Groups Projects
Commit 3eecc32a authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

Task #10339: get export_d from job_id if export_id not available

parent 1a70750c
No related branches found
No related tags found
No related merge requests found
......@@ -65,6 +65,15 @@ class IngestBusListenerForMomAdapter(IngestBusListener):
if msg.content.get('type','').lower() == 'mom':
export_id = msg.content.get('export_id')
if export_id is None:
try:
#try to get export_id from job_id
job_id = msg.content.get('job_id')
if job_id:
export_id = int(job_id.split('_')[1])
except:
pass #don't care
if export_id and export_id not in self._momrpc.getProjectDetails(export_id):
logger.warn('Export job %s cannot be found (anymore) in mom. Removing export job from ingest queue', export_id)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment