def METHOD_NAME(
    publisher_client: pubsub_v1.PublisherClient, topic_path: str
) -> None:
    iam.set_topic_policy(PROJECT_ID, TOPIC_ID)
    policy = publisher_client.get_iam_policy(request={"resource": topic_path})
    assert "roles/pubsub.publisher" in str(policy)
    assert "domain:google.com" in str(policy)