[ext] unstructured log forwarding

dagster-io · Sep 21, 2023 · f1f6cdb · f1f6cdb
1 parent c7293a9
commit f1f6cdb
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]: ...