Handle op outputs in default asset IO manager (#8074)

dagster-io · May 31, 2022 · 6b8f907 · 6b8f907 · vercel · May 31, 2022
1 parent 8551940
commit 6b8f907
Show file tree

Hide file tree

Showing 19 changed files with 724 additions and 1,131 deletions.
diff --git a/docs/content/api/modules.json b/docs/content/api/modules.json
diff --git a/docs/content/api/searchindex.json b/docs/content/api/searchindex.json
diff --git a/docs/content/api/sections.json b/docs/content/api/sections.json
diff --git a/docs/content/concepts/assets/software-defined-assets.mdx b/docs/content/concepts/assets/software-defined-assets.mdx
@@ -207,7 +207,7 @@ Different assets can have different IO managers:
 ```python file=/concepts/assets/asset_different_io_managers.py startafter=start_marker endbefore=end_marker
 from dagster_aws.s3 import s3_pickle_asset_io_manager, s3_resource
 
-from dagster import AssetGroup, asset, fs_asset_io_manager
+from dagster import AssetGroup, asset, fs_io_manager
 
 
 @asset(io_manager_key="s3_io_manager")
@@ -225,7 +225,7 @@ asset_group = AssetGroup(
     resource_defs={
         "s3_io_manager": s3_pickle_asset_io_manager,
         "s3": s3_resource,
-        "fs_io_manager": fs_asset_io_manager,
+        "fs_io_manager": fs_io_manager,
     },
 )
 ```
@@ -237,7 +237,7 @@ The same assets can be bound to different resources and IO managers in different
 ```python file=/concepts/assets/asset_io_manager_prod_local.py startafter=start_marker endbefore=end_marker
 from dagster_aws.s3 import s3_pickle_asset_io_manager, s3_resource
 
-from dagster import AssetGroup, asset, fs_asset_io_manager
+from dagster import AssetGroup, asset, fs_io_manager
 
 
 @asset
@@ -257,7 +257,7 @@ prod_asset_group = AssetGroup(
 
 local_asset_group = AssetGroup(
     [upstream_asset, downstream_asset],
-    resource_defs={"io_manager": fs_asset_io_manager},
+    resource_defs={"io_manager": fs_io_manager},
 )
 ```
 

diff --git a/docs/next/public/objects.inv b/docs/next/public/objects.inv
diff --git a/docs/sphinx/sections/api/apidocs/assets.rst b/docs/sphinx/sections/api/apidocs/assets.rst
@@ -24,6 +24,3 @@ A software-defined asset combines:
 .. autoclass:: AssetIn
 
 .. autoclass:: SourceAsset
-
-.. autoconfigurable:: fs_asset_io_manager
-  :annotation: IOManagerDefinition
diff --git a/examples/docs_snippets/docs_snippets/concepts/assets/asset_different_io_managers.py b/examples/docs_snippets/docs_snippets/concepts/assets/asset_different_io_managers.py
@@ -2,7 +2,7 @@
 # start_marker
 from dagster_aws.s3 import s3_pickle_asset_io_manager, s3_resource
 
-from dagster import AssetGroup, asset, fs_asset_io_manager
+from dagster import AssetGroup, asset, fs_io_manager
 
 
 @asset(io_manager_key="s3_io_manager")
@@ -20,7 +20,7 @@ def downstream_asset(upstream_asset):
     resource_defs={
         "s3_io_manager": s3_pickle_asset_io_manager,
         "s3": s3_resource,
-        "fs_io_manager": fs_asset_io_manager,
+        "fs_io_manager": fs_io_manager,
     },
 )
 

diff --git a/examples/docs_snippets/docs_snippets/concepts/assets/asset_io_manager_prod_local.py b/examples/docs_snippets/docs_snippets/concepts/assets/asset_io_manager_prod_local.py
@@ -2,7 +2,7 @@
 # start_marker
 from dagster_aws.s3 import s3_pickle_asset_io_manager, s3_resource
 
-from dagster import AssetGroup, asset, fs_asset_io_manager
+from dagster import AssetGroup, asset, fs_io_manager
 
 
 @asset
@@ -22,7 +22,7 @@ def downstream_asset(upstream_asset):
 
 local_asset_group = AssetGroup(
     [upstream_asset, downstream_asset],
-    resource_defs={"io_manager": fs_asset_io_manager},
+    resource_defs={"io_manager": fs_io_manager},
 )
 
 # end_marker