[pipes] fix a few typos (#16861)

## How I Tested These Changes eyes
dagster-io · Sep 27, 2023 · 9960687 · 9960687
1 parent 1084d20
commit 9960687
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/python_modules/dagster-pipes/dagster_pipes/__init__.py b/python_modules/dagster-pipes/dagster_pipes/__init__.py
@@ -685,7 +685,7 @@ def set(cls, context: "PipesContext") -> None:
     def get(cls) -> "PipesContext":
         if cls._instance is None:
             raise Exception(
-                "ExtContext has not been initialized. You must call `init_dagster_ext()`."
+                "ExtContext has not been initialized. You must call `init_dagster_pipes()`."
             )
         return cls._instance
 

diff --git a/python_modules/libraries/dagster-docker/dagster_docker/pipes.py b/python_modules/libraries/dagster-docker/dagster_docker/pipes.py
@@ -122,7 +122,7 @@ def run(
                 Extra values to pass along as part of the ext protocol.
             context_injector (Optional[PipesContextInjector]):
                 Override the default ext protocol context injection.
-            message_Reader (Optional[PipesMessageReader]):
+            message_reader (Optional[PipesMessageReader]):
                 Override the default ext protocol message reader.
 
         Yields:

diff --git a/python_modules/libraries/dagster-k8s/dagster_k8s/pipes.py b/python_modules/libraries/dagster-k8s/dagster_k8s/pipes.py
@@ -157,7 +157,7 @@ def run(
                 Extra values to pass along as part of the ext protocol.
             context_injector (Optional[PipesContextInjector]):
                 Override the default ext protocol context injection.
-            message_Reader (Optional[PipesMessageReader]):
+            message_reader (Optional[PipesMessageReader]):
                 Override the default ext protocol message reader.
 
         Yields: