def test_publish_message(self):
        """Try to publish a message and check the output for the  message."""
        for message in self.messages:
            with captured_output() as (out, _):
                main(['pubsub_sample.py', get_project_id(), 'publish_message',
                      self.topic, message])
                output = out.getvalue().strip()
            self.assertTrue(output in message)
dataset/ETHPy150Open GoogleCloudPlatform/cloud-pubsub-samples-python/cmdline-pull/test_pubsub_sample.py/PubsubSampleTestCase.test_publish_message/swapped operands of `in`