"""Util modules for Apple Music Source of Streams flow.""" from garcon.contrib.dynamo_feed_status import \ feed_status_ingestion as feed_status def is_apple_music_ingested(date): """Check if apple music streams flow ingested for given date. Args: date (str): Date in sting format 'YYYY-MM-DD'. Returns: bool: True if data ingested for all given date. """ status = feed_status.get_overall_status('apple_music_streams', date) return status == feed_status.STATUS_INGESTED