publisher_client = 
topic = 'projects/python-docs-samples-tests/topics/subscription-test-topic-3.8-7caeeb931df34a1f9c660ec6c5a91847'
subscription_async = 'projects/python-docs-samples-tests/subscriptions/subscription-test-subscription-async-3.8-7caeeb931df34a1f9c660ec6c5a91847'
capsys = <_pytest.capture.CaptureFixture object at 0x7fddce0499a0>
def test_receive_with_custom_attributes(
    publisher_client, topic, subscription_async, capsys
):

    _publish_messages(publisher_client, topic, origin="python-sample")

    subscriber.receive_messages_with_custom_attributes(
        PROJECT_ID, SUBSCRIPTION_ASYNC, 5
    )

    out, _ = capsys.readouterr()
    assert subscription_async in out
    assert "message" in out


  assert "origin" in out


E       AssertionError: assert 'origin' in 'Listening for messages on projects/python-docs-samples-tests/subscriptions/subscription-test-subscription-async-3.8-7caeeb931df34a1f9c660ec6c5a91847..\n\n'
subscriber_test.py:384: AssertionError