[ext] unstructured log forwarding

dagster-io · Sep 22, 2023 · eb84985 · eb84985
1 parent 1b8e161
commit eb84985
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/python_modules/dagster/dagster/_core/ext/client.py b/python_modules/dagster/dagster/_core/ext/client.py
@@ -34,3 +34,9 @@ class ExtMessageReader(ABC):
     @abstractmethod
     @contextmanager
     def read_messages(self, handler: "ExtMessageHandler") -> Iterator[ExtParams]: ...
+
+
+class ExtLogReader(ABC):
+    @abstractmethod
+    @contextmanager
+    def read_logs(self) -> Iterator[ExtParams]: ...