def export_asset()

in subscribers/python/pandas-describe-csv/pandas-describe-csv.py [0:0]

• 23 lines of code
• 4 McCabe index (conditional complexity)

def export_asset(asset, bucket):
    asset_id = asset.get('Id')

    job = dx.create_job(Type='EXPORT_ASSETS_TO_S3', Details={
        "ExportAssetsToS3": {
            "RevisionId": asset.get("RevisionId"), "DataSetId": asset.get("DataSetId"),
            "AssetDestinations": [{
                "AssetId": asset_id,
                "Bucket": bucket,
                "Key": asset_id
            }]
        }
    })

    job_id = job.get('Id')
    dx.start_job(JobId=job_id)

    while True:
        job = dx.get_job(JobId=job_id)

        if job.get('State') == 'COMPLETED':
            break
        elif job.get('State') == 'ERROR':
            raise Exception("Job {} failed to complete - {}".format(
                job_id, job.get('Errors')[0].get('Message'))
            )

        time.sleep(1)