"""Select all in-progress ingestions.""" SELECT_IN_PROGRESS_INGESTIONS = """ SELECT * FROM {catalog}.{schema}.{env}_BULK_ASSET_SFN_QUEUE b WHERE b.end_time IS NULL AND b.start_time IS NOT NULL and b.execution_name is NOT NULL AND b.status NOT IN (%(finished_status_list)s) AND b.status IN (%(in_progress_status_list)s) ORDER BY b.start_time ASC ; """