def METHOD_NAME(self, mock_headers: Mock, queue: Queue) -> None:
    send_telemetry(topic="topic")
    queue.join()  # Wait for the telemetry tasks to be completed
    self.mock_head.assert_called_once()
    mock_headers.assert_called_once()
    self.assertEqual(self.mock_head.call_args[1]["headers"], mock_headers.return_value)