waltertschwe

 def import_fields(self, alerts):
        residents = self.meta.tables['application_resident']
        for alert in alerts:
            resident = self.get_fields(alert)
            query = residents.select((residents.c.resident_number == resident['resident_number']) & (residents.c.facility_id == resident['facility_id']))
            hello = query.execute()
            rows = hello.fetchall()
            if not rows:
                insert_stmt = insert(self.meta.tables['application_resident']).values(resident)
                self.con.execute(insert_stmt)