refactor(config): rename Config → OrcapodConfig

src/orcapod/__init__.py

@@ -1,3 +1,4 @@
+from .config import OrcapodConfig
 from .core.function_pod import (
     FunctionPod,
     function_pod,
@@ -14,6 +15,7 @@
 from . import types  # noqa: F401
 
 __all__ = [
+    "OrcapodConfig",
     "FunctionPod",
     "function_pod",
     "Pipeline",

src/orcapod/config.py

@@ -4,24 +4,24 @@
 
 
 @dataclass(frozen=True)
-class Config:
-    """Immutable configuration object."""
+class OrcapodConfig:
+    """Immutable OrcaPod configuration object."""
 
     system_tag_hash_n_char: int = 12
     schema_hash_n_char: int = 12
     path_hash_n_char: int = 20
 
     def with_updates(self, **kwargs) -> Self:
-        """Create a new Config instance with updated values."""
+        """Create a new ``OrcapodConfig`` instance with updated values."""
         return replace(self, **kwargs)
 
-    def merge(self, other: "Config") -> "Config":
+    def merge(self, other: "OrcapodConfig") -> "OrcapodConfig":
         """Merge with another config, other takes precedence."""
-        if not isinstance(other, Config):
-            raise TypeError("Can only merge with another Config instance")
+        if not isinstance(other, OrcapodConfig):
+            raise TypeError("Can only merge with another OrcapodConfig instance")
 
         # Get all non-default values from other
-        defaults = Config()
+        defaults = OrcapodConfig()
         updates = {}
         for field_name in self.__dataclass_fields__:
             other_value = getattr(other, field_name)
@@ -33,4 +33,4 @@ def merge(self, other: "Config") -> "Config":
 
 
 # Module-level default config - created at import time
-DEFAULT_CONFIG = Config()
+DEFAULT_CONFIG = OrcapodConfig()

src/orcapod/core/base.py

@@ -6,7 +6,7 @@
 from typing import Any
 
 import orcapod.contexts as contexts
-from orcapod.config import DEFAULT_CONFIG, Config
+from orcapod.config import DEFAULT_CONFIG, OrcapodConfig
 from orcapod.types import ContentHash
 
 logger = logging.getLogger(__name__)
@@ -75,7 +75,7 @@ class DataContextMixin:
     def __init__(
         self,
         data_context: str | contexts.DataContext | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
         **kwargs,
     ):
         super().__init__(**kwargs)
@@ -85,7 +85,7 @@ def __init__(
         self._orcapod_config = config
 
     @property
-    def orcapod_config(self) -> Config:
+    def orcapod_config(self) -> OrcapodConfig:
         return self._orcapod_config
 
     @property
@@ -117,7 +117,7 @@ class ContentIdentifiableBase(DataContextMixin, ABC):
     def __init__(
         self,
         data_context: str | contexts.DataContext | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
         **kwargs: Any,
     ) -> None:
         """
@@ -360,7 +360,7 @@ def __init__(
         self,
         label: str | None = None,
         data_context: str | contexts.DataContext | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
     ):
         # Init provided here for explicit listing of parmeters
         super().__init__(label=label, data_context=data_context, config=config)

src/orcapod/core/data_function.py

@@ -11,7 +11,7 @@
 
 from uuid_utils import uuid7
 
-from orcapod.config import Config
+from orcapod.config import OrcapodConfig
 from orcapod.contexts import DataContext
 from orcapod.core.base import TraceableBase
 from orcapod.core.datagrams import Datagram, Data
@@ -135,7 +135,7 @@ def __init__(
         version: str = "v0.0",
         label: str | None = None,
         data_context: str | DataContext | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
         executor: DataFunctionExecutorProtocol | None = None,
     ):
         super().__init__(label=label, data_context=data_context, config=config)
@@ -374,7 +374,7 @@ def __init__(
         output_schema: SchemaLike | Sequence[type] | None = None,
         label: str | None = None,
         data_context: str | DataContext | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
         executor: PythonFunctionExecutorProtocol | None = None,
     ) -> None:
 

src/orcapod/core/datagrams/datagram.py

@@ -26,7 +26,7 @@
 from uuid_utils import uuid7
 
 from orcapod import contexts
-from orcapod.config import Config
+from orcapod.config import OrcapodConfig
 from orcapod.core.base import ContentIdentifiableBase
 from orcapod.protocols.semantic_types_protocols import TypeConverterProtocol
 from orcapod.semantic_types import infer_python_schema_from_pylist_data
@@ -68,7 +68,7 @@ def __init__(
         meta_info: Mapping[str, DataValue] | None = None,
         record_id: str | None = None,
         data_context: str | contexts.DataContext | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
     ) -> None:
         if isinstance(data, pa.RecordBatch):
             data = pa.Table.from_batches([data])

src/orcapod/core/function_pod.py

@@ -9,7 +9,7 @@
 
 from orcapod import contexts
 from orcapod.channels import ReadableChannel, WritableChannel
-from orcapod.config import Config
+from orcapod.config import OrcapodConfig
 from orcapod.core.base import TraceableBase
 from orcapod.core.data_function import CachedDataFunction, PythonDataFunction
 from orcapod.core.streams.base import StreamBase
@@ -65,7 +65,7 @@ def __init__(
         tracker_manager: TrackerManagerProtocol | None = None,
         label: str | None = None,
         data_context: str | contexts.DataContext | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
     ) -> None:
         super().__init__(
             label=label,

src/orcapod/core/nodes/function_node.py

@@ -23,7 +23,7 @@
 
 from orcapod import contexts
 from orcapod.channels import ReadableChannel, WritableChannel
-from orcapod.config import Config
+from orcapod.config import OrcapodConfig
 from orcapod.core.cached_function_pod import CachedFunctionPod
 from orcapod.core.streams.arrow_table_stream import ArrowTableStream
 from orcapod.core.streams.base import StreamBase
@@ -96,7 +96,7 @@ def __init__(
         input_stream: StreamProtocol,
         tracker_manager: TrackerManagerProtocol | None = None,
         label: str | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
         table_scope: Literal["pipeline_hash", "content_hash"] = "pipeline_hash",
     ):
         if tracker_manager is None:
@@ -450,7 +450,7 @@ def __init__(
         input_stream: StreamProtocol,
         tracker_manager: TrackerManagerProtocol | None = None,
         label: str | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
         table_scope: Literal["pipeline_hash", "content_hash"] = "pipeline_hash",
     ):
         super().__init__(
@@ -664,7 +664,7 @@ def __init__(
         input_stream: StreamProtocol,
         tracker_manager: TrackerManagerProtocol | None = None,
         label: str | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
         # Optional DB params for persistent mode:
         pipeline_database: ArrowDatabaseProtocol | None = None,
         result_database: ArrowDatabaseProtocol | None = None,

src/orcapod/core/nodes/operator_node.py

@@ -23,7 +23,7 @@
 
 from orcapod import contexts
 from orcapod.channels import Channel, ReadableChannel, WritableChannel
-from orcapod.config import Config
+from orcapod.config import OrcapodConfig
 from orcapod.core.operators.static_output_pod import StaticOutputOperatorPod
 from orcapod.core.streams.arrow_table_stream import ArrowTableStream
 from orcapod.core.streams.base import StreamBase
@@ -74,7 +74,7 @@ def __init__(
         input_streams: Collection[StreamProtocol],
         tracker_manager: TrackerManagerProtocol | None = None,
         label: str | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
         table_scope: Literal["pipeline_hash", "content_hash"] = "pipeline_hash",
     ) -> None:
         """Initialize the shared operator-node state.
@@ -517,7 +517,7 @@ def __init__(
         input_streams: tuple[StreamProtocol, ...] | list[StreamProtocol],
         tracker_manager: TrackerManagerProtocol | None = None,
         label: str | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
         # Optional DB params for persistent mode:
         pipeline_database: ArrowDatabaseProtocol | None = None,
         cache_mode: CacheMode = CacheMode.OFF,

src/orcapod/core/nodes/source_node.py

@@ -12,7 +12,7 @@
 from typing import TYPE_CHECKING, Any
 
 from orcapod import contexts
-from orcapod.config import Config
+from orcapod.config import OrcapodConfig
 from orcapod.core.base import TraceableBase
 from orcapod.errors import SourceSpecMismatchError, UnboundSourceError
 from orcapod.protocols.core_protocols import DataProtocol, TagProtocol
@@ -55,7 +55,7 @@ def __init__(
         data_schema: Schema,
         data_context: str | contexts.DataContext | None = None,
         label: str | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
     ) -> None:
         super().__init__(label=label, data_context=data_context, config=config)
         self._name = name

src/orcapod/core/operators/static_output_pod.py

@@ -8,7 +8,7 @@
 from typing import TYPE_CHECKING, Any, cast
 
 from orcapod.channels import ReadableChannel, WritableChannel
-from orcapod.config import Config
+from orcapod.config import OrcapodConfig
 from orcapod.contexts import DataContext
 from orcapod.core.base import TraceableBase
 from orcapod.core.streams.base import StreamBase
@@ -269,7 +269,7 @@ def __init__(
         upstreams: tuple[StreamProtocol, ...] = (),
         label: str | None = None,
         data_context: DataContext | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
     ) -> None:
         self._pod = pod
         self._upstreams = upstreams

src/orcapod/core/sources/base.py

@@ -5,7 +5,7 @@
 from typing import TYPE_CHECKING, Any
 
 from orcapod import contexts
-from orcapod.config import Config
+from orcapod.config import OrcapodConfig
 from orcapod.core.streams.base import StreamBase
 from orcapod.protocols.core_protocols import StreamProtocol
 from orcapod.types import ColumnConfig, Schema
@@ -60,7 +60,7 @@ def __init__(
         source_id: str | None = None,
         label: str | None = None,
         data_context: str | contexts.DataContext | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
     ) -> None:
         super().__init__(
             label=label,

src/orcapod/core/sources/cached_source.py

@@ -5,7 +5,7 @@
 from typing import TYPE_CHECKING, Any
 
 from orcapod import contexts
-from orcapod.config import Config
+from orcapod.config import OrcapodConfig
 from orcapod.core.sources.base import RootSource
 from orcapod.core.streams.arrow_table_stream import ArrowTableStream
 from orcapod.protocols.core_protocols import DataProtocol, SourceProtocol, TagProtocol
@@ -59,7 +59,7 @@ def __init__(
         source_id: str | None = None,
         label: str | None = None,
         data_context: str | contexts.DataContext | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
     ) -> None:
         if data_context is None:
             data_context = source.data_context_key

src/orcapod/core/sources/db_table_source.py

@@ -23,7 +23,7 @@
     import pyarrow as pa
 
     from orcapod import contexts
-    from orcapod.config import Config
+    from orcapod.config import OrcapodConfig
     from orcapod.protocols.db_connector_protocol import DBConnectorProtocol
 else:
     pa = LazyModule("pyarrow")
@@ -69,7 +69,7 @@ def __init__(
         source_id: str | None = None,
         label: str | None = None,
         data_context: str | contexts.DataContext | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
         *,
         _query: str | None = None,
     ) -> None:

src/orcapod/core/sources/postgresql_table_source.py

@@ -19,7 +19,7 @@
 
 if TYPE_CHECKING:
     from orcapod import contexts
-    from orcapod.config import Config
+    from orcapod.config import OrcapodConfig
 
 
 class PostgreSQLTableSource(DBTableSource):
@@ -69,7 +69,7 @@ def __init__(
         source_id: str | None = None,
         label: str | None = None,
         data_context: str | contexts.DataContext | None = None,
-        config: Config | None = None,
+        config: OrcapodConfig | None = None,
     ) -> None:
         self._dsn = dsn  # store before try — needed by to_config even if super() raises
         connector = PostgreSQLConnector(dsn)  # outside try — if this raises, finally never runs

src/orcapod/core/sources/spiraldb_table_source.py

@@ -42,7 +42,7 @@
 
 if TYPE_CHECKING:
     from orcapod import contexts
-    from orcapod.config import Config
+    from orcapod.config import OrcapodConfig
 
 
 class SpiralDBTableSource(DBTableSource):
@@ -98,7 +98,7 @@ def __init__(
         source_id: str | None = None,
         label: str | None = None,
         data_context: "str | contexts.DataContext | None" = None,
-        config: "Config | None" = None,
+        config: "OrcapodConfig | None" = None,
         overrides: dict[str, str] | None = None,
     ) -> None:
         self._project_id = project_id

src/orcapod/core/sources/sqlite_table_source.py

@@ -29,7 +29,7 @@
 
 if TYPE_CHECKING:
     from orcapod import contexts
-    from orcapod.config import Config
+    from orcapod.config import OrcapodConfig
 
 
 class SQLiteTableSource(DBTableSource):
@@ -79,7 +79,7 @@ def __init__(
         source_id: str | None = None,
         label: str | None = None,
         data_context: str | contexts.DataContext | None = None,
-        config: "Config | None" = None,
+        config: "OrcapodConfig | None" = None,
     ) -> None:
         self._db_path = db_path
         connector = SQLiteConnector(db_path)

src/orcapod/core/sources/stream_builder.py

@@ -21,7 +21,7 @@
 if TYPE_CHECKING:
     import pyarrow as pa
 
-    from orcapod.config import Config
+    from orcapod.config import OrcapodConfig
     from orcapod.contexts import DataContext
 else:
     pa = LazyModule("pyarrow")
@@ -59,7 +59,7 @@ class SourceStreamBuilder:
         config: Orcapod config (controls hash character counts).
     """
 
-    def __init__(self, data_context: DataContext, config: Config) -> None:
+    def __init__(self, data_context: DataContext, config: OrcapodConfig) -> None:
         self._data_context = data_context
         self._config = config