def batch_job_status()

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')