Сервисы
executor
Исполнитель узлов Conveyor — забирает задачи из очереди, выполняет шаг и отдаёт результат в control-plane.
executor (executor-runtime) — рабочий процесс, который непосредственно исполняет узлы сценария: забирает задачу из очереди, выполняет шаг в изолированном workspace и возвращает результат в runtime-control-plane по HTTP. Масштабируется горизонтально.
На какие вопросы отвечает раздел: Кто выполняет шаги? Куда он отдаёт результат? Где исполняется код узла?
Цель
Выполнить конкретный шаг процесса в изолированном workspace и вернуть результат в control-plane.
Задачи
- pull задач из Redis (BullMQ);
- запуск логики узла в рабочем каталоге
RUN_WORKSPACE_PATH; - отправка ack/result в control-plane по HTTP.
Требования
- Redis (очереди);
- доступ к runtime-control-plane (HTTP) и (для LLM-узлов) к Ollama;
- общий
PLUGIN_CONTROL_PLANE_KEY.
Ограничения
- единственный канал с оркестрацией: HTTP ack/result в control-plane.
- stateless: состояние Запуска не хранит, только возвращает результат шага.
Настройки и переменные окружения
| Переменная | Зачем | На что влияет | По умолчанию |
|---|---|---|---|
CONTROL_PLANE_HTTP_BASE_URL | Адрес control-plane | Куда отдавать ack/result | http://runtime-control-plane:3000 |
RUNTIME_INTERNAL_BASE_URL | Внутренний адрес рантайма | Служебные вызовы | http://runtime-engine:3000 |
RUN_WORKSPACE_PATH | Каталог исполнения шага | Где разворачивается рабочее окружение узла | /tmp/flowforge-runs |
PLUGIN_CONTROL_PLANE_KEY | Ключ control-plane | Авторизация при отправке результатов | — |
OLLAMA_BASE_URL | Адрес LLM | Выполнение LLM-узлов | http://ollama:11434 |
REDIS_HOST / REDIS_PORT | Очереди | Откуда берутся задачи | redis / 6379 |