diff --git a/docs/content/api/modules.json.gz b/docs/content/api/modules.json.gz index 249c79e11d6bb..01343aaf12cf4 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 1c0f33537da40..a71bd248da98c 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 3bd83eb889bb0..d61cd91c5b0ea 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/kubernetes.mdx b/docs/content/concepts/dagster-pipes/kubernetes.mdx index 327b9877bbca1..129d8297062c8 100644 --- a/docs/content/concepts/dagster-pipes/kubernetes.mdx +++ b/docs/content/concepts/dagster-pipes/kubernetes.mdx @@ -51,17 +51,13 @@ from dagster_pipes import open_dagster_pipes with open_dagster_pipes() as pipes: # Stream log message back to Dagster - pipes.log.info("Started computation") + pipes.log.info(f"Using some_parameter value: {pipes.get_extra('some_parameter')}") # ... your code that computes and persists the asset - # Stream asset materialization metadata and data version back to Dagster. - # This should be called after you've computed and stored the asset value. We - # omit the asset key here because there is only one asset in scope, but for - # multi-assets you can pass an `asset_key` parameter. pipes.report_asset_materialization( metadata={ - "some_metric": {"raw_value": 1, "type": "int"} + "some_metric": {"raw_value": 2, "type": "int"} }, data_version="alpha", ) @@ -123,6 +119,9 @@ def k8s_pipes_asset(context: AssetExecutionContext, k8s_pipes_client: PipesK8sCl return k8s_pipes_client.run( context=context, image="pipes-example:v1", + extras={ + "some_parameter": 1 + } ).get_materialize_result() ``` @@ -194,6 +193,9 @@ def k8s_pipes_asset(context: AssetExecutionContext, k8s_pipes_client: PipesK8sCl return k8s_pipes_client.run( context=context, image="pipes-example:v1", + extras={ + "some_parameter": 1 + } ).get_materialize_result() diff --git a/docs/next/public/objects.inv b/docs/next/public/objects.inv index 249fa54423a91..036f4fd4d3e58 100644 Binary files a/docs/next/public/objects.inv and b/docs/next/public/objects.inv differ