From eb8498578acdb0cf83a9fc0a723cc97d81625f92 Mon Sep 17 00:00:00 2001 From: Sean Mackesey Date: Tue, 19 Sep 2023 15:12:40 -0400 Subject: [PATCH] [ext] unstructured log forwarding --- python_modules/dagster/dagster/_core/ext/client.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/python_modules/dagster/dagster/_core/ext/client.py b/python_modules/dagster/dagster/_core/ext/client.py index 5d96312eb9eb7..6884b86385d94 100644 --- 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]: ...