def METHOD_NAME(self, queue: Queue) -> None:
    send_telemetry(topic="foo bar")
    queue.join()  # Wait for the telemetry tasks to be completed
    self.mock_head.assert_called_once()
    self.assertEqual(self.mock_head.call_args[0][0], f"{ENDPOINT_STAGING}/api/telemetry/foo%20bar")