def verify_published_data(self, crash_id, pubsub):
    if ('PUBSUB_EMULATOR_HOST' in os.environ):
        crash_ids = [crash_id.decode('utf-8') for crash_id in pubsub.list_crashids()]
        assert (crash_id in crash_ids)
    else:
        print('SKIPPING PUBLISH CHECK--NOT USING EMULATOR')
def verify_published_data(self, crash_id, pubsub):
    if ('PUBSUB_EMULATOR_HOST' in os.environ):
        crash_ids = [crash_id.decode('utf-8') for crash_id in pubsub.list_crashids()]
        assert (crash_id in crash_ids)
    else:
        print('SKIPPING PUBLISH CHECK--NOT USING EMULATOR')