"""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 ORDER BY b.start_time ASC ; """