mirror of
https://github.com/bytedance/deer-flow.git
synced 2026-08-01 10:56:02 +00:00
3c8b82c594
* fix(runtime): serialize checkpoint writes with active runs * fix(runtime): address checkpoint reservation reviews * fix(runtime): address reservation race reviews * fix(runtime): refine reservation conflict semantics
29 lines
596 B
Python
29 lines
596 B
Python
"""Run status and disconnect mode enums."""
|
|
|
|
from enum import StrEnum
|
|
|
|
|
|
class ThreadOperationKind(StrEnum):
|
|
"""Kind of operation holding exclusive admission for a thread."""
|
|
|
|
run = "run"
|
|
checkpoint_write = "checkpoint_write"
|
|
|
|
|
|
class RunStatus(StrEnum):
|
|
"""Lifecycle status of a single run."""
|
|
|
|
pending = "pending"
|
|
running = "running"
|
|
success = "success"
|
|
error = "error"
|
|
timeout = "timeout"
|
|
interrupted = "interrupted"
|
|
|
|
|
|
class DisconnectMode(StrEnum):
|
|
"""Behaviour when the SSE consumer disconnects."""
|
|
|
|
cancel = "cancel"
|
|
continue_ = "continue"
|