7029fcc6ff92856d43119a56b9d3367ae0fd7b55,container_registry/container_analysis/samples_test.py,TestContainerAnalysisSamples,test_pubsub,#TestContainerAnalysisSamples#,130

Before Change

        samples.create_occurrence_subscription(subscription_id, PROJECT_ID)
        tries = 0
        success = False
        while not success and tries < TRY_LIMIT:
            print(tries)
            tries += 1
            receiver = samples.MessageReceiver()
            client.subscribe(subscription_name, receiver.pubsub_callback)

            // test adding 3 more occurrences
            total_created = 3
            for _ in range(total_created):
                occ = samples.create_occurrence(self.image_url,
                                                self.note_id,
                                                PROJECT_ID,
                                                PROJECT_ID)
                sleep(SLEEP_TIME)
                samples.delete_occurrence(basename(occ.name), PROJECT_ID)
                sleep(SLEEP_TIME)
            print("done. msg_count = {}".format(receiver.msg_count))
            success = receiver.msg_count == total_created
        assert receiver.msg_count == total_created
        // clean up
        client.delete_subscription(subscription_name)

After Change

        except AlreadyExists:
            pass

        subscription_id = "container-analysis-test-{}".format(uuid.uuid4())
        subscription_name = client.subscription_path(PROJECT_ID,
                                                     subscription_id)
        samples.create_occurrence_subscription(subscription_id, PROJECT_ID)

Instances