setActiveTasks(prev => const newMap = new Map(prev); newMap.set(taskId, ...prev.get(taskId)!, status: taskData.status, progress: taskData.progress ); return newMap; ); // If completed, trigger download if (taskData.status === 'completed') downloadCompletedFile(taskId); catch (error) console.error('Failed to poll task status:', error);
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") how to download vmdk file from datastore
export default VMDKDownloadManager; # docker-compose.yml version: '3.8' services: redis: image: redis:7-alpine ports: - "6379:6379" volumes: - redis_data:/data const newMap = new Map(prev)
return response @app.get("/api/v1/download/file/task_id") async def download_file(task_id: str): """Download the completed VMDK file""" task = download_vmdk_task.AsyncResult(task_id) progress: taskData.progress )
postgres: image: postgres:15 environment: POSTGRES_DB: vmdk_downloads POSTGRES_USER: vmdk_user POSTGRES_PASSWORD: secure_password volumes: - postgres_data:/var/lib/postgresql/data
title: 'Message', dataIndex: 'message', key: 'message', ellipsis: true