async def METHOD_NAME(self, variables, eventgrid_cloud_event_topic_endpoint):
    client = self.create_eg_publisher_client(eventgrid_cloud_event_topic_endpoint)
    attributes = {
        "type": "com.example.sampletype1",
        "source": "https://example.com/event-producer",
        "ext1": "extension"
    }
    data = "hello world"
    cloud_event = CloudEvent(attributes, data)
    await client.send([cloud_event])