def remove_stale_files()

in gnm_deliverables/tasks.py [0:0]

• 14 lines of code
• 5 McCabe index (conditional complexity)

def remove_stale_files():
    """
    Remove files from disk for deliverable assets after they are ingested.

    IMPORTANT: Make sure write permissions exists for the directories created for deliverables for the user running
    celery.

    :return:
    """
    raven_client = init_raven()
    try:
        assets = DeliverableAsset.objects.filter(file_removed_dt__isnull=True)
        logger.info('Trying to removing files for {count} deliverables'.format(count=assets.count()))
        for asset in assets:
            user = User.objects.get(username=settings.VIDISPINE_USERNAME)
            status = asset.status(user)
            if status != DELIVERABLE_ASSET_STATUS_INGESTED:
                logger.debug('Not removing file for asset "{asset}": File not ingested yet'.format(asset=asset))
    except Exception as e:
        if raven_client is not None:
            raven_client.captureException()
        raise e