No ExclusiveJoinTask builder class — defaultExclusiveJoinTask field unreachable
评估
- 难度
- 3/5
- 预计耗时
- 1-2 天
- 新手友好度
- 68/100
- Issue 类型
- 功能
- 描述清晰度
- 描述清楚
- 活跃度
- 冷清
- 技术栈
- python
调研方向
定位现有的 JoinTask 和 TaskInterface 入口点，然后检查它们如何创建 WorkflowTask 并分配 TaskType。为使用 join_on 和 default_exclusive_join_task 构造 EXCLUSIVE_JOIN 任务添加覆盖；当 SDK 能够序列化这些字段，并且生成的 workflow 对未匹配的 SWITCH 分支正确运行时，即表示完成。
由索引模型根据 Issue 内容生成。
描述
Summary
Tested against: Conductor OSS 3.32.0-rc.9
TaskType.EXCLUSIVE_JOIN exists in the SDK enum but there is no ExclusiveJoinTask
builder class. More critically, the defaultExclusiveJoinTask field (which tells
the server which task to use when no SWITCH branch ran) cannot be set through any
SDK path.
Details
JoinTask always produces TaskType.JOIN, not TaskType.EXCLUSIVE_JOIN. There
is no way to build an EXCLUSIVE_JOIN task using SDK classes alone.
EXCLUSIVE_JOIN is designed for SWITCH branches (where exactly one branch executes).
Without defaultExclusiveJoinTask set, EXCLUSIVE_JOIN workflows with a branch that
doesn't match will stall.
Suggested fix
class ExclusiveJoinTask(TaskInterface):
def __init__(self, task_ref_name: str, join_on: List[str],
default_exclusive_join_task: Optional[List[str]] = None):
super().__init__(task_ref_name, TaskType.EXCLUSIVE_JOIN)
self._join_on = join_on
self._default = default_exclusive_join_task or []
def to_workflow_task(self) -> WorkflowTask:
wf = super().to_workflow_task()
wf.join_on = self._join_on
wf.default_exclusive_join_task = self._default
return wf
Verified against
Conductor server 3.32.0-rc.9. EXCLUSIVE_JOIN runs correctly when built via
raw WorkflowTask with the correct fields set. The gap is purely in the SDK —
no builder class exists.
- 主要语言
- Python
- 星标
- 104
- 派生
- 44
- 平均合并
- 4 天 18 小时
- 30 天内合并 PR
- 3
环境准备
- 提供 Dockerfile 或 Docker Compose 文件
- 没有 Pull Request 模板
- 没有贡献指南
从这里开始
- 先读完整个 Issue，再读项目的贡献指南。
- 在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
- Fork 仓库，在一个分支上完成修改。
- 提交 Pull Request，并在描述里引用这个 Issue 编号。
conductor-oss/python-sdk 的其他 Issue
-
Async SSE client reuses httpx.AsyncClient across event loops -> "Event loop is closed"可能已有人在做 关联的 PR 仍在进行中或已合并。 未关闭bug
难度 2/5 1-3 小时 新手友好度 78/100
conductor-oss/python-sdk#507 ·
-
`.[agents]` extra omits `langchain-anthropic`, so a shipped example cannot run可能已有人在做 关联的 PR 仍在进行中或已合并。 未关闭bug dependencies
难度 2/5 1-3 小时 新手友好度 88/100
conductor-oss/python-sdk#486 ·
-
Framework-agent failures return `None` instead of the failed task's reason可能重新可做 关联的 PR 已关闭且未合并。 未关闭bug
难度 2/5 1-3 小时 新手友好度 78/100
conductor-oss/python-sdk#483 ·
-
bug
难度 2/5 1-3 小时 新手友好度 82/100
conductor-oss/python-sdk#478 ·
-
Example 39c_serverless_code_execution.py needs to be changed for it to work可能已有人在做 @nthmost-orkes 于 11 天前认领。 未关闭
难度 1/5 1 小时以内 新手友好度 90/100
conductor-oss/python-sdk#512 ·
查看 conductor-oss/python-sdk 的全部 Issue
相似的 Issue
-
难度 2/5 1-3 小时 新手友好度 72/100
Juniper/ansible-junos-stdlib#904 ·
-
难度 2/5 1-3 小时 新手友好度 82/100
pollen-robotics/reachy_mini#1457 ·
维护者通常 1 天内回复
-
area:runtime good first issue
难度 2/5 1-3 小时 新手友好度 72/100
WATonomous/wato_f1tenth#39 ·
-
难度 2/5 1-3 小时 新手友好度 82/100
FireDynamics/fdsreader#123 ·
-
难度 1/5 1 小时以内 新手友好度 85/100