in configurations/RedshiftConfigTestingLambda.py [0:0]
def batch_job_status(job_id, extract_s3_path=None):
if job_id == "N/A":
return "FINISHED"
else:
job_stats = boto3.client('batch').describe_jobs(jobs=[job_id]).get('jobs')[0]
if job_stats.get('status') == "FAILED":
raise Exception('Error:' + str(job_stats))
elif job_stats.get('status') == "SUCCEEDED":
return "FINISHED"
else:
return job_stats.get('status')