def METHOD_NAME(self, records):
    # Zenpy client credentials to connect to API
    creds = {
        'email': 'dev@stitchdata.com',
        'password': os.getenv('TAP_ZENDESK_API_PASSWORD'),
        'subdomain': "rjmdev",
    }
    test_tags = ['test_tag_1', 'test_tag_2', 'test_tag_3']
    # filter out closed tickets since we cannot update them to refresh thier tags
    unclosed_tickets = [t for t in records.get('tickets').get('messages') if t.get('data').get('status') != 'closed']
    self.assertGreaterEqual(len(unclosed_tickets), 3)
    last_3_unclosed_tickets = unclosed_tickets[-3:]
    zenpy_client = Zenpy(**creds)
    for i, tic in enumerate(last_3_unclosed_tickets):
        # remove and re-add  existing tags to refresh
        if tic.get('data').get('tags'):
            tag_list = tic.get('data').get('tags')
            zenpy_client.tickets.delete_tags(tic.get('data').get('id'), tag_list)
            # replace old tags. adding the same tag does not create duplicates
            zenpy_client.tickets.add_tags(tic.get('data').get('id'), tag_list)
        # add / refresh test tags
        zenpy_client.tickets.add_tags(tic.get('data').get('id'), test_tags[0:(i+1)])
        # mark tags as refreshed as soon as we successfully get through one loop
        self.tags_are_stale = False