Remove batch commands

src/resonate/actions.py

@@ -5,7 +5,7 @@
 
 from typing_extensions import Self
 
-from resonate.dataclasses import BatchCommand, DurablePromise
+from resonate.dataclasses import DurablePromise
 from resonate.options import Options
 
 if TYPE_CHECKING:
@@ -49,7 +49,7 @@ def to_rfi(self) -> RFI:
 @final
 @dataclass
 class LFC:
-    unit: Invocation[Any] | BatchCommand
+    unit: Invocation[Any]
     opts: Options = field(default=Options())
 
     def options(
@@ -86,7 +86,7 @@ def options(self) -> Self:
 @final
 @dataclass
 class LFI:
-    unit: Invocation[Any] | BatchCommand
+    unit: Invocation[Any]
     opts: Options = field(default=Options())
 
     def options(

src/resonate/context.py

@@ -11,7 +11,7 @@
     RFC,
     RFI,
 )
-from resonate.dataclasses import BatchCommand, DurablePromise, Invocation, RegisteredFn
+from resonate.dataclasses import DurablePromise, Invocation, RegisteredFn
 from resonate.time import now
 
 if TYPE_CHECKING:
@@ -133,8 +133,6 @@ def rfi(
     ) -> RFI:
         return self.rfc(func_or_cmd, *args, **kwargs).to_rfi()
 
-    @overload
-    def lfi(self, cmd: BatchCommand, /) -> LFI: ...
     @overload
     def lfi(
         self,
@@ -161,10 +159,7 @@ def lfi(
     ) -> LFI: ...
     def lfi(
         self,
-        func_or_cmd: DurableCoro[P, T]
-        | DurableFn[P, T]
-        | BatchCommand
-        | RegisteredFn[P, T],
+        func_or_cmd: DurableCoro[P, T] | DurableFn[P, T] | RegisteredFn[P, T],
         /,
         *args: P.args,
         **kwargs: P.kwargs,
@@ -180,8 +175,6 @@ def lfi(
         """
         return self.lfc(func_or_cmd, *args, **kwargs).to_lfi()
 
-    @overload
-    def lfc(self, func: BatchCommand, /) -> LFC: ...
     @overload
     def lfc(
         self,
@@ -208,10 +201,7 @@ def lfc(
     ) -> LFC: ...
     def lfc(
         self,
-        func_or_cmd: DurableCoro[P, T]
-        | DurableFn[P, T]
-        | BatchCommand
-        | RegisteredFn[P, T],
+        func_or_cmd: DurableCoro[P, T] | DurableFn[P, T] | RegisteredFn[P, T],
         /,
         *args: P.args,
         **kwargs: P.kwargs,
@@ -222,10 +212,8 @@ def lfc(
         LFC and await for the result of the execution. It's syntax
         sugar for `yield (yield ctx.lfi(...))`
         """
-        unit: BatchCommand | Invocation[Any]
-        if isinstance(func_or_cmd, BatchCommand):
-            unit = func_or_cmd
-        elif isinstance(func_or_cmd, RegisteredFn):
+        unit: Invocation[Any]
+        if isinstance(func_or_cmd, RegisteredFn):
             unit = Invocation(func_or_cmd.fn, *args, **kwargs)
         else:
             unit = Invocation(func_or_cmd, *args, **kwargs)

src/resonate/dataclasses.py

@@ -160,9 +160,6 @@ def __init__(
         self.kwargs = kwargs
 
 
-class BatchCommand: ...
-
-
 class DurablePromise:
     def __init__(
         self,

src/resonate/processor/traits.py

@@ -3,12 +3,12 @@
 from abc import ABC, abstractmethod
 from typing import TYPE_CHECKING, Any
 
-from resonate.traits import SubSystem
+from resonate.traits import Subsystem
 
 if TYPE_CHECKING:
     from resonate.dataclasses import SQE
 
 
-class IProcessor(SubSystem, ABC):
+class IProcessor(Subsystem, ABC):
     @abstractmethod
     def enqueue(self, sqe: SQE[Any]) -> None: ...

src/resonate/queue.py

@@ -8,7 +8,7 @@
 from typing import Optional, TypeVar, final
 
 from resonate.cmd_queue import CommandQ, Invoke
-from resonate.traits import SubSystem
+from resonate.traits import Subsystem
 
 T = TypeVar("T")
 
@@ -22,7 +22,7 @@ def _secs_to_ns(secs: float) -> float:
 
 
 @final
-class DelayQueue(SubSystem):
+class DelayQueue(Subsystem):
     def __init__(self) -> None:
         self._inq = Queue[Optional[tuple[Invoke, float]]]()
         self._delayed: list[tuple[float, Invoke]] = []

src/resonate/task_sources/traits.py

@@ -3,10 +3,10 @@
 from abc import ABC, abstractmethod
 from typing import Any
 
-from resonate.traits import SubSystem
+from resonate.traits import Subsystem
 
 
-class ITaskSource(SubSystem, ABC):
+class ITaskSource(Subsystem, ABC):
     @abstractmethod
     def set_pid(self, pid: str) -> None: ...
     @abstractmethod

src/resonate/traits.py

@@ -7,7 +7,7 @@
     from resonate.cmd_queue import CommandQ
 
 
-class SubSystem(ABC):
+class Subsystem(ABC):
     @abstractmethod
     def start(self, cmd_queue: CommandQ) -> None: ...