Handle ImageGeneration tasks in _pending_tasks

This commit is contained in:
ciaranbor
2026-01-06 10:03:18 +00:00
parent 8e23841b4e
commit bedb9045a0
+4 -1
View File
@@ -9,6 +9,7 @@ from exo.shared.types.tasks import (
ConnectToGroup,
CreateRunner,
DownloadModel,
ImageGeneration,
LoadModel,
Shutdown,
StartWarmup,
@@ -265,7 +266,9 @@ def _pending_tasks(
) -> Task | None:
for task in tasks.values():
# for now, just forward chat completions
if not isinstance(task, ChatCompletion):
if not isinstance(task, ChatCompletion) and not isinstance(
task, ImageGeneration
):
continue
if task.task_status not in (TaskStatus.Pending, TaskStatus.Running):
continue