diff --git a/docs/content/api/modules.json.gz b/docs/content/api/modules.json.gz index 3930da2c16840..3a1092493fb02 100644 Binary files a/docs/content/api/modules.json.gz and b/docs/content/api/modules.json.gz differ diff --git a/docs/content/api/searchindex.json.gz b/docs/content/api/searchindex.json.gz index 1faf44f410954..bd6ab5ab3e0f3 100644 Binary files a/docs/content/api/searchindex.json.gz and b/docs/content/api/searchindex.json.gz differ diff --git a/docs/content/api/sections.json.gz b/docs/content/api/sections.json.gz index aa1367b7d9f80..e45907c94c272 100644 Binary files a/docs/content/api/sections.json.gz and b/docs/content/api/sections.json.gz differ diff --git a/docs/content/concepts/dagster-pipes/aws-glue.mdx b/docs/content/concepts/dagster-pipes/aws-glue.mdx index 6c4c584597ff0..82737f6586600 100644 --- a/docs/content/concepts/dagster-pipes/aws-glue.mdx +++ b/docs/content/concepts/dagster-pipes/aws-glue.mdx @@ -107,8 +107,7 @@ Next, add the `PipesGlueClient` resource to your project's str: - return "Attempted to inject context via Glue job Arguments" - - -class PipesGlueLogsMessageReader(PipesCloudWatchMessageReader): - pass - - @experimental class PipesGlueClient(PipesClient, TreatAsResourceParam): """A pipes client for invoking AWS Glue jobs. Args: context_injector (Optional[PipesContextInjector]): A context injector to use to inject - context into the Glue job, for example, :py:class:`PipesGlueContextInjector`. + context into the Glue job, for example, :py:class:`PipesS3ContextInjector`. message_reader (Optional[PipesMessageReader]): A message reader to use to read messages - from the glue job run. Defaults to :py:class:`PipesGlueLogsMessageReader`. + from the glue job run. Defaults to :py:class:`PipesCloudWatchsMessageReader`. client (Optional[boto3.client]): The boto Glue client used to launch the Glue job """ @@ -363,7 +354,7 @@ def __init__( ): self._client = client or boto3.client("glue") self._context_injector = context_injector - self._message_reader = message_reader or PipesGlueLogsMessageReader() + self._message_reader = message_reader or PipesCloudWatchMessageReader() @classmethod def _is_dagster_maintained(cls) -> bool: