diff --git a/docs/content/api/modules.json.gz b/docs/content/api/modules.json.gz index fc2b8e7acde70..06ccaae0e6374 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 344fec5d97d9d..baa41aa919c4f 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 2719a26b1c11a..951a54a553360 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: