Method callback

new_ui/backend/services/workflow_service.py:123–140

(progress: int, message: str)

        task = self._tasks.get(task_id)

        def callback(progress: int, message: str):
            if task:
                task.progress = progress
                task.message = message

            # Broadcast to all subscribers
            asyncio.create_task(
                self._broadcast(
                    task_id,
                    {
                        "type": "progress",
                        "task_id": task_id,
                        "progress": progress,
                        "message": message,
                        "timestamp": datetime.utcnow().isoformat(),
                    },
                )
            )

        return callback