def METHOD_NAME(
    topic_path: str, capsys: CaptureFixture[str]
) -> None:
    publisher.publish_messages_with_error_handler(PROJECT_ID, TOPIC_ID)
    out, _ = capsys.readouterr()
    assert f"Published messages with error handler to {topic_path}." in out