[ext] unstructured log forwarding

dagster-io · Sep 21, 2023 · f38de5b · f38de5b
1 parent 4b1eae1
commit f38de5b
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
@@ -36,3 +36,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]: ...