"""Select all SFN queue items that are not yet executed.""" SELECT_ORPHANED_SFN_QUEUE_ITEMS = """ SELECT * FROM {catalog}.{schema}.{env}_BULK_ASSET_SFN_QUEUE WHERE START_TIME IS NOT NULL AND EXECUTION_NAME IS NULL AND STATUS IN (%(orphaned_status_list)s) ORDER BY ID ASC ; """