[components] component_type -> registered_component_type (BUILD-655)

[INTERNAL_BRANCH=sean/components/registered-component-type]

examples/docs_beta_snippets/docs_beta_snippets/guides/components/custom-subclass/basic-subclass.py

@@ -1,6 +1,6 @@
-from dagster_components import component_type
+from dagster_components import registered_component_type
 from dagster_components.lib import SlingReplicationCollection
 
 
-@component_type(name="custom_subclass")
+@registered_component_type(name="custom_subclass")
 class CustomSubclass(SlingReplicationCollection): ...

examples/docs_beta_snippets/docs_beta_snippets/guides/components/custom-subclass/custom-scope.py

@@ -1,13 +1,13 @@
 from collections.abc import Mapping
 from typing import Any
 
-from dagster_components import component_type
+from dagster_components import registered_component_type
 from dagster_components.lib import SlingReplicationCollection
 
 import dagster as dg
 
 
-@component_type(name="custom_subclass")
+@registered_component_type(name="custom_subclass")
 class SubclassWithScope(SlingReplicationCollection):
     def get_additional_scope(self) -> Mapping[str, Any]:
         def _custom_cron(cron_schedule: str) -> dg.AutomationCondition:

examples/docs_beta_snippets/docs_beta_snippets/guides/components/custom-subclass/debug-mode.py

@@ -1,13 +1,13 @@
 from collections.abc import Iterator
 
-from dagster_components import component_type
+from dagster_components import registered_component_type
 from dagster_components.lib import SlingReplicationCollection
 from dagster_sling import SlingResource
 
 import dagster as dg
 
 
-@component_type(name="debug_sling_replication")
+@registered_component_type(name="debug_sling_replication")
 class DebugSlingReplicationComponent(SlingReplicationCollection):
     def execute(
         self, context: dg.AssetExecutionContext, sling: SlingResource

examples/docs_beta_snippets/docs_beta_snippets/guides/components/shell-script-component/empty.py

@@ -1,10 +1,14 @@
-from dagster_components import Component, ComponentLoadContext, component_type
+from dagster_components import (
+    Component,
+    ComponentLoadContext,
+    registered_component_type,
+)
 from pydantic import BaseModel
 
 from dagster import Definitions
 
 
-@component_type(name="shell_command")
+@registered_component_type(name="shell_command")
 class ShellCommand(Component):
     @classmethod
     def get_schema(cls) -> type[BaseModel]: ...

examples/docs_beta_snippets/docs_beta_snippets/guides/components/shell-script-component/resolving-resolvable-field.py

@@ -1,4 +1,8 @@
-from dagster_components import Component, ComponentLoadContext, component_type
+from dagster_components import (
+    Component,
+    ComponentLoadContext,
+    registered_component_type,
+)
 
 import dagster as dg
 
@@ -10,7 +14,7 @@ def _get_script_runner(val: str) -> ScriptRunner:
     return ScriptRunner()
 
 
-@component_type(name="shell_command")
+@registered_component_type(name="shell_command")
 class ShellCommand(Component):
     def __init__(self, params):
         self.params = params

examples/docs_beta_snippets/docs_beta_snippets/guides/components/shell-script-component/with-build-defs.py

@@ -1,7 +1,11 @@
 import subprocess
 from typing import Optional
 
-from dagster_components import Component, ComponentLoadContext, component_type
+from dagster_components import (
+    Component,
+    ComponentLoadContext,
+    registered_component_type,
+)
 from dagster_components.core.schema.objects import AssetAttributesModel, OpSpecModel
 from pydantic import BaseModel
 
@@ -16,7 +20,7 @@ class ShellScriptSchema(BaseModel):
     # highlight-end
 
 
-@component_type(name="shell_command")
+@registered_component_type(name="shell_command")
 class ShellCommand(Component):
     def __init__(self, params: ShellScriptSchema):
         self.params = params

examples/docs_beta_snippets/docs_beta_snippets/guides/components/shell-script-component/with-config-schema.py

@@ -1,6 +1,10 @@
 from typing import Optional
 
-from dagster_components import Component, ComponentLoadContext, component_type
+from dagster_components import (
+    Component,
+    ComponentLoadContext,
+    registered_component_type,
+)
 from dagster_components.core.schema.objects import AssetAttributesModel, OpSpecModel
 from pydantic import BaseModel
 
@@ -15,7 +19,7 @@ class ShellScriptSchema(BaseModel):
     # highlight-end
 
 
-@component_type(name="shell_command")
+@registered_component_type(name="shell_command")
 class ShellCommand(Component):
     @classmethod
     def get_schema(cls) -> type[ShellScriptSchema]:

python_modules/libraries/dagster-components/dagster_components/__init__.py

@@ -2,7 +2,7 @@
     Component as Component,
     ComponentLoadContext as ComponentLoadContext,
     ComponentTypeRegistry as ComponentTypeRegistry,
-    component_type as component_type,
+    registered_component_type as registered_component_type,
 )
 from dagster_components.core.component_defs_builder import (
     build_component_defs as build_component_defs,

python_modules/libraries/dagster-components/dagster_components/core/component.py

@@ -254,7 +254,9 @@ def for_decl_node(self, decl_node: ComponentDeclNode) -> "ComponentLoadContext":
 COMPONENT_LOADER_FN_ATTR = "__dagster_component_loader_fn"
 
 
-def component_type(cls: Optional[type[Component]] = None, *, name: Optional[str] = None) -> Any:
+def registered_component_type(
+    cls: Optional[type[Component]] = None, *, name: Optional[str] = None
+) -> Any:
     """Decorator for registering a component type. You must annotate a component
     type with this decorator in order for it to be inspectable and loaded by tools.
 

python_modules/libraries/dagster-components/dagster_components/lib/dbt_project/component.py

@@ -12,7 +12,7 @@
 )
 
 from dagster_components import Component, ComponentLoadContext
-from dagster_components.core.component import component_type
+from dagster_components.core.component import registered_component_type
 from dagster_components.core.schema.base import ResolvableModel
 from dagster_components.core.schema.metadata import ResolvableFieldInfo
 from dagster_components.core.schema.objects import (
@@ -46,7 +46,7 @@ def resolve(self, resolver: TemplatedValueResolver) -> "DbtProjectComponent":
         )
 
 
-@component_type(name="dbt_project")
+@registered_component_type(name="dbt_project")
 class DbtProjectComponent(Component):
     """Expose a DBT project to Dagster as a set of assets."""
 

python_modules/libraries/dagster-components/dagster_components/lib/definitions_component/component.py

@@ -10,15 +10,15 @@
 from pydantic import BaseModel
 from typing_extensions import Self
 
-from dagster_components import Component, ComponentLoadContext, component_type
+from dagster_components import Component, ComponentLoadContext, registered_component_type
 from dagster_components.lib.definitions_component.scaffolder import DefinitionsComponentScaffolder
 
 
 class DefinitionsParamSchema(BaseModel):
     definitions_path: Optional[str] = None
 
 
-@component_type(name="definitions")
+@registered_component_type(name="definitions")
 class DefinitionsComponent(Component):
     """Wraps an arbitrary set of Dagster definitions."""
 

python_modules/libraries/dagster-components/dagster_components/lib/pipes_subprocess_script_collection.py

@@ -10,7 +10,11 @@
 from dagster._core.pipes.subprocess import PipesSubprocessClient
 from pydantic import BaseModel
 
-from dagster_components.core.component import Component, ComponentLoadContext, component_type
+from dagster_components.core.component import (
+    Component,
+    ComponentLoadContext,
+    registered_component_type,
+)
 from dagster_components.core.schema.base import ResolvableModel
 from dagster_components.core.schema.objects import AssetSpecModel
 from dagster_components.core.schema.resolver import TemplatedValueResolver
@@ -36,7 +40,7 @@ def resolve(self, resolver: TemplatedValueResolver) -> Mapping[str, Sequence[Ass
         }
 
 
-@component_type(name="pipes_subprocess_script_collection")
+@registered_component_type(name="pipes_subprocess_script_collection")
 class PipesSubprocessScriptCollection(Component):
     """Assets that wrap Python scripts executed with Dagster's PipesSubprocessClient."""
 

python_modules/libraries/dagster-components/dagster_components/lib/sling_replication_collection/component.py

@@ -12,7 +12,7 @@
 from typing_extensions import Self
 
 from dagster_components import Component, ComponentLoadContext
-from dagster_components.core.component import component_type
+from dagster_components.core.component import registered_component_type
 from dagster_components.core.component_scaffolder import ComponentScaffolder
 from dagster_components.core.schema.metadata import ResolvableFieldInfo
 from dagster_components.core.schema.objects import (
@@ -73,7 +73,7 @@ def resolve(self, resolver: TemplatedValueResolver) -> ResolvedSlingReplicationC
         )
 
 
-@component_type
+@registered_component_type
 class SlingReplicationCollection(Component):
     """Expose one or more Sling replications to Dagster as assets."""
 

python_modules/libraries/dagster-components/dagster_components/lib/test/all_metadata_empty_asset.py

@@ -3,11 +3,11 @@
 from dagster._core.execution.context.asset_execution_context import AssetExecutionContext
 from typing_extensions import Self
 
-from dagster_components import Component, ComponentLoadContext, component_type
+from dagster_components import Component, ComponentLoadContext, registered_component_type
 from dagster_components.core.component_scaffolder import DefaultComponentScaffolder
 
 
-@component_type(name="all_metadata_empty_asset")
+@registered_component_type(name="all_metadata_empty_asset")
 class AllMetadataEmptyAsset(Component):
     @classmethod
     def load(cls, context: "ComponentLoadContext") -> Self:

python_modules/libraries/dagster-components/dagster_components/lib/test/complex_schema_asset.py

@@ -7,7 +7,7 @@
 from pydantic import BaseModel
 from typing_extensions import Self
 
-from dagster_components import Component, ComponentLoadContext, component_type
+from dagster_components import Component, ComponentLoadContext, registered_component_type
 from dagster_components.core.component_scaffolder import DefaultComponentScaffolder
 from dagster_components.core.schema.metadata import ResolvableFieldInfo
 from dagster_components.core.schema.objects import (
@@ -26,7 +26,7 @@ class ComplexAssetParams(BaseModel):
     asset_transforms: Optional[Sequence[AssetSpecTransformModel]] = None
 
 
-@component_type(name="complex_schema_asset")
+@registered_component_type(name="complex_schema_asset")
 class ComplexSchemaAsset(Component):
     """An asset that has a complex params schema."""
 

python_modules/libraries/dagster-components/dagster_components/lib/test/simple_asset.py

@@ -5,7 +5,7 @@
 from pydantic import BaseModel
 from typing_extensions import Self
 
-from dagster_components import Component, ComponentLoadContext, component_type
+from dagster_components import Component, ComponentLoadContext, registered_component_type
 from dagster_components.core.component_scaffolder import (
     ComponentScaffolder,
     DefaultComponentScaffolder,
@@ -17,7 +17,7 @@ class SimpleAssetParams(BaseModel):
     value: str
 
 
-@component_type(name="simple_asset")
+@registered_component_type(name="simple_asset")
 class SimpleAsset(Component):
     """A simple asset that returns a constant string value."""
 

python_modules/libraries/dagster-components/dagster_components/lib/test/simple_pipes_script_asset.py

@@ -9,7 +9,7 @@
 from pydantic import BaseModel
 from typing_extensions import Self
 
-from dagster_components import Component, ComponentLoadContext, component_type
+from dagster_components import Component, ComponentLoadContext, registered_component_type
 from dagster_components.core.component_scaffolder import (
     ComponentScaffolder,
     ComponentScaffoldRequest,
@@ -47,7 +47,7 @@ def scaffold(
 """
 
 
-@component_type(name="simple_pipes_script_asset")
+@registered_component_type(name="simple_pipes_script_asset")
 class SimplePipesScriptAsset(Component):
     """A simple asset that runs a Python script with the Pipes subprocess client.
 

python_modules/libraries/dagster-components/dagster_components/test/basic_components.py

@@ -6,7 +6,7 @@
 from pydantic import BaseModel, ConfigDict
 from typing_extensions import Self
 
-from dagster_components import Component, component_type
+from dagster_components import Component, registered_component_type
 from dagster_components.core.component import ComponentLoadContext
 
 
@@ -17,7 +17,7 @@ class MyComponentSchema(BaseModel):
     model_config = ConfigDict(extra="forbid")
 
 
-@component_type
+@registered_component_type
 class MyComponent(Component):
     name = "my_component"
 
@@ -46,7 +46,7 @@ class MyNestedComponentSchema(BaseModel):
     model_config = ConfigDict(extra="forbid")
 
 
-@component_type
+@registered_component_type
 class MyNestedComponent(Component):
     name = "my_nested_component"
 

python_modules/libraries/dagster-components/dagster_components_tests/code_locations/custom_sling_location/custom_sling_location/components/debug_sling_component/component.py

@@ -1,12 +1,12 @@
 from collections.abc import Iterator
 
 from dagster._core.execution.context.asset_execution_context import AssetExecutionContext
-from dagster_components import component_type
+from dagster_components import registered_component_type
 from dagster_components.lib.sling_replication_collection.component import SlingReplicationCollection
 from dagster_sling import SlingResource
 
 
-@component_type(name="debug_sling_replication")
+@registered_component_type(name="debug_sling_replication")
 class DebugSlingReplicationComponent(SlingReplicationCollection):
     def execute(self, context: AssetExecutionContext, sling: SlingResource) -> Iterator:
         return sling.replicate(context=context, debug=True)

python_modules/libraries/dagster-components/dagster_components_tests/integration_tests/components/definitions/local_component_sample/__init__.py

@@ -1,5 +1,5 @@
 from dagster._core.definitions.definitions_class import Definitions
-from dagster_components import Component, component_type
+from dagster_components import Component, registered_component_type
 from dagster_components.core.component import ComponentLoadContext
 from dagster_components.core.schema.base import BaseModel
 from typing_extensions import Self
@@ -10,7 +10,7 @@ class MyComponentSchema(BaseModel):
     an_int: int
 
 
-@component_type
+@registered_component_type
 class MyComponent(Component):
     name = "my_component"
 

python_modules/libraries/dagster-components/dagster_components_tests/integration_tests/components/definitions/other_local_component_sample/__init__.py

@@ -1,5 +1,5 @@
 from dagster._core.definitions.definitions_class import Definitions
-from dagster_components import Component, component_type
+from dagster_components import Component, registered_component_type
 from dagster_components.core.component import ComponentLoadContext
 from pydantic import BaseModel
 from typing_extensions import Self
@@ -10,7 +10,7 @@ class MyNewComponentSchema(BaseModel):
     an_int: int
 
 
-@component_type
+@registered_component_type
 class MyNewComponent(Component):
     name = "my_new_component"
 

python_modules/libraries/dagster-components/dagster_components_tests/integration_tests/test_sling_integration_test.py

@@ -12,7 +12,7 @@
 from dagster._core.definitions.result import MaterializeResult
 from dagster._core.execution.context.asset_execution_context import AssetExecutionContext
 from dagster._utils.env import environ
-from dagster_components import component_type
+from dagster_components import registered_component_type
 from dagster_components.core.component_decl_builder import ComponentFileModel
 from dagster_components.core.component_defs_builder import (
     YamlComponentDecl,
@@ -163,7 +163,7 @@ def test_load_from_path(sling_path: Path) -> None:
 
 
 def test_sling_subclass() -> None:
-    @component_type(name="debug_sling_replication")
+    @registered_component_type(name="debug_sling_replication")
     class DebugSlingReplicationComponent(SlingReplicationCollection):
         def execute(
             self, context: AssetExecutionContext, sling: SlingResource

python_modules/libraries/dagster-components/dagster_components_tests/registry_tests/test_registry.py

@@ -55,8 +55,8 @@ def _find_repo_root():
 
 def _generate_test_component_source(number: int) -> str:
     return textwrap.dedent(f"""
-    from dagster_components import Component, component_type
-    @component_type(name="test_component_{number}")
+    from dagster_components import Component, registered_component_type
+    @registered_component_type(name="test_component_{number}")
     class TestComponent{number}(Component):
         pass
     """)