const pollTaskStatus = async (taskId: string) => try const response = await axios.get( /api/v1/download/status/$taskId ); const taskData = response.data;
return () => intervals.forEach(interval => clearInterval(interval)); , [activeTasks]); how to download vmdk file from datastore
setActiveTasks(prev => const newMap = new Map(prev); newMap.set(taskId, ); return newMap; ); // If completed, trigger download if (taskData.status === 'completed') downloadCompletedFile(taskId); catch (error) console.error('Failed to poll task status:', error); const pollTaskStatus = async (taskId: string) => try
file_path = task.result['file_path'] file_name = task.result['file_name'] const taskData = response.data
async def _stream_download(self, url: str): """Stream download with authentication""" import aiohttp # Create session with vCenter authentication session = aiohttp.ClientSession( auth=aiohttp.BasicAuth(self.connection._stub.cookie), connector=aiohttp.TCPConnector(verify_ssl=False) ) response = await session.get(url) return response @celery_app.task(bind=True, name="download_vmdk_task") def download_vmdk_task(self, request_data: Dict[str, Any]): """Celery task for async VMDK download""" try: # Update task state self.update_state(state="PROGRESS", meta="progress": 0, "status": "Connecting to vCenter")
async def get_vmdk_file_path(self, vm, vmdk_filename: str) -> Optional[str]: """Get VMDK file path in datastore""" for device in vm.config.hardware.device: if isinstance(device, vim.vm.device.VirtualDisk): if device.backing.fileName.endswith(vmdk_filename): return device.backing.fileName return None