Upload folder using huggingface_hub

envs/finrl_env/server/finrl_environment.py

@@ -13,8 +13,14 @@ Wraps FinRL's StockTradingEnv to conform to the OpenEnv interface.
 from uuid import uuid4
 
 import numpy as np
-from openenv.core.env_server.interfaces import Environment
-from openenv.core.env_server.types import State
+
+try:
+    # Prefer legacy /app/src/core import path in staged HF deployments.
+    from core.env_server.interfaces import Environment
+    from core.env_server.types import State
+except ImportError:
+    from openenv.core.env_server.interfaces import Environment
+    from openenv.core.env_server.types import State
 
 from ..models import FinRLAction, FinRLObservation
 

server/finrl_environment.py

@@ -13,8 +13,14 @@ Wraps FinRL's StockTradingEnv to conform to the OpenEnv interface.
 from uuid import uuid4
 
 import numpy as np
-from openenv.core.env_server.interfaces import Environment
-from openenv.core.env_server.types import State
+
+try:
+    # Prefer legacy /app/src/core import path in staged HF deployments.
+    from core.env_server.interfaces import Environment
+    from core.env_server.types import State
+except ImportError:
+    from openenv.core.env_server.interfaces import Environment
+    from openenv.core.env_server.types import State
 
 from ..models import FinRLAction, FinRLObservation
 

src/core/__init__.py

@@ -6,13 +6,12 @@
 
 """Core components for agentic environments."""
 
-# Re-export main components from submodules for convenience
-from .env_server import *  # noqa: F403
+from __future__ import annotations
+
+from importlib import import_module
+
 from . import env_server
-from .env_client import EnvClient
-from .sync_client import SyncEnvClient
-from .generic_client import GenericEnvClient, GenericAction
-from .mcp_client import MCPClientBase, MCPToolClient
+from .env_server import *  # noqa: F403
 
 __all__ = [
     "EnvClient",
@@ -22,3 +21,34 @@ __all__ = [
     "MCPClientBase",
     "MCPToolClient",
 ] + env_server.__all__  # type: ignore
+
+
+_LAZY_ATTRS = {
+    "EnvClient": (".env_client", "EnvClient"),
+    "SyncEnvClient": (".sync_client", "SyncEnvClient"),
+    "GenericEnvClient": (".generic_client", "GenericEnvClient"),
+    "GenericAction": (".generic_client", "GenericAction"),
+    "MCPClientBase": (".mcp_client", "MCPClientBase"),
+    "MCPToolClient": (".mcp_client", "MCPToolClient"),
+}
+
+
+def __getattr__(name: str):
+    if name in _LAZY_ATTRS:
+        module_path, attr_name = _LAZY_ATTRS[name]
+        module = import_module(module_path, __name__)
+        value = getattr(module, attr_name)
+        globals()[name] = value
+        return value
+
+    try:
+        value = getattr(env_server, name)
+    except AttributeError as exc:
+        raise AttributeError(f"module {__name__!r} has no attribute {name!r}") from exc
+
+    globals()[name] = value
+    return value
+
+
+def __dir__() -> list[str]:
+    return sorted(set(globals().keys()) | set(__all__))

src/core/openenv/__init__.py

@@ -1,11 +1,8 @@
-"""
-Unified OpenEnv package bundling the CLI and core runtime.
-"""
+"""Unified OpenEnv package bundling the CLI and core runtime."""
 
-from importlib import metadata
+from __future__ import annotations
 
-from .auto import AutoAction, AutoEnv
-from .core import GenericEnvClient, GenericAction, SyncEnvClient
+from importlib import import_module, metadata
 
 __all__ = [
     "core",
@@ -21,3 +18,37 @@ try:
     __version__ = metadata.version("openenv")  # type: ignore[arg-type]
 except metadata.PackageNotFoundError:  # pragma: no cover - local dev
     __version__ = "0.0.0"
+
+
+_LAZY_MODULES = {
+    "core": ".core",
+    "cli": ".cli",
+}
+
+_LAZY_ATTRS = {
+    "AutoEnv": (".auto", "AutoEnv"),
+    "AutoAction": (".auto", "AutoAction"),
+    "GenericEnvClient": (".core", "GenericEnvClient"),
+    "GenericAction": (".core", "GenericAction"),
+    "SyncEnvClient": (".core", "SyncEnvClient"),
+}
+
+
+def __getattr__(name: str):
+    if name in _LAZY_MODULES:
+        module = import_module(_LAZY_MODULES[name], __name__)
+        globals()[name] = module
+        return module
+
+    if name in _LAZY_ATTRS:
+        module_path, attr_name = _LAZY_ATTRS[name]
+        module = import_module(module_path, __name__)
+        value = getattr(module, attr_name)
+        globals()[name] = value
+        return value
+
+    raise AttributeError(f"module {__name__!r} has no attribute {name!r}")
+
+
+def __dir__() -> list[str]:
+    return sorted(set(globals().keys()) | set(__all__))

src/core/openenv/core/__init__.py

@@ -6,13 +6,12 @@
 
 """Core components for agentic environments."""
 
-# Re-export main components from submodules for convenience
-from .env_server import *  # noqa: F403
+from __future__ import annotations
+
+from importlib import import_module
+
 from . import env_server
-from .env_client import EnvClient
-from .sync_client import SyncEnvClient
-from .generic_client import GenericEnvClient, GenericAction
-from .mcp_client import MCPClientBase, MCPToolClient
+from .env_server import *  # noqa: F403
 
 __all__ = [
     "EnvClient",
@@ -22,3 +21,34 @@ __all__ = [
     "MCPClientBase",
     "MCPToolClient",
 ] + env_server.__all__  # type: ignore
+
+
+_LAZY_ATTRS = {
+    "EnvClient": (".env_client", "EnvClient"),
+    "SyncEnvClient": (".sync_client", "SyncEnvClient"),
+    "GenericEnvClient": (".generic_client", "GenericEnvClient"),
+    "GenericAction": (".generic_client", "GenericAction"),
+    "MCPClientBase": (".mcp_client", "MCPClientBase"),
+    "MCPToolClient": (".mcp_client", "MCPToolClient"),
+}
+
+
+def __getattr__(name: str):
+    if name in _LAZY_ATTRS:
+        module_path, attr_name = _LAZY_ATTRS[name]
+        module = import_module(module_path, __name__)
+        value = getattr(module, attr_name)
+        globals()[name] = value
+        return value
+
+    try:
+        value = getattr(env_server, name)
+    except AttributeError as exc:
+        raise AttributeError(f"module {__name__!r} has no attribute {name!r}") from exc
+
+    globals()[name] = value
+    return value
+
+
+def __dir__() -> list[str]:
+    return sorted(set(globals().keys()) | set(__all__))

src/openenv/__init__.py

@@ -1,11 +1,8 @@
-"""
-Unified OpenEnv package bundling the CLI and core runtime.
-"""
+"""Unified OpenEnv package bundling the CLI and core runtime."""
 
-from importlib import metadata
+from __future__ import annotations
 
-from .auto import AutoAction, AutoEnv
-from .core import GenericEnvClient, GenericAction, SyncEnvClient
+from importlib import import_module, metadata
 
 __all__ = [
     "core",
@@ -21,3 +18,37 @@ try:
     __version__ = metadata.version("openenv")  # type: ignore[arg-type]
 except metadata.PackageNotFoundError:  # pragma: no cover - local dev
     __version__ = "0.0.0"
+
+
+_LAZY_MODULES = {
+    "core": ".core",
+    "cli": ".cli",
+}
+
+_LAZY_ATTRS = {
+    "AutoEnv": (".auto", "AutoEnv"),
+    "AutoAction": (".auto", "AutoAction"),
+    "GenericEnvClient": (".core", "GenericEnvClient"),
+    "GenericAction": (".core", "GenericAction"),
+    "SyncEnvClient": (".core", "SyncEnvClient"),
+}
+
+
+def __getattr__(name: str):
+    if name in _LAZY_MODULES:
+        module = import_module(_LAZY_MODULES[name], __name__)
+        globals()[name] = module
+        return module
+
+    if name in _LAZY_ATTRS:
+        module_path, attr_name = _LAZY_ATTRS[name]
+        module = import_module(module_path, __name__)
+        value = getattr(module, attr_name)
+        globals()[name] = value
+        return value
+
+    raise AttributeError(f"module {__name__!r} has no attribute {name!r}")
+
+
+def __dir__() -> list[str]:
+    return sorted(set(globals().keys()) | set(__all__))

src/openenv/core/__init__.py

@@ -6,13 +6,12 @@
 
 """Core components for agentic environments."""
 
-# Re-export main components from submodules for convenience
-from .env_server import *  # noqa: F403
+from __future__ import annotations
+
+from importlib import import_module
+
 from . import env_server
-from .env_client import EnvClient
-from .sync_client import SyncEnvClient
-from .generic_client import GenericEnvClient, GenericAction
-from .mcp_client import MCPClientBase, MCPToolClient
+from .env_server import *  # noqa: F403
 
 __all__ = [
     "EnvClient",
@@ -22,3 +21,34 @@ __all__ = [
     "MCPClientBase",
     "MCPToolClient",
 ] + env_server.__all__  # type: ignore
+
+
+_LAZY_ATTRS = {
+    "EnvClient": (".env_client", "EnvClient"),
+    "SyncEnvClient": (".sync_client", "SyncEnvClient"),
+    "GenericEnvClient": (".generic_client", "GenericEnvClient"),
+    "GenericAction": (".generic_client", "GenericAction"),
+    "MCPClientBase": (".mcp_client", "MCPClientBase"),
+    "MCPToolClient": (".mcp_client", "MCPToolClient"),
+}
+
+
+def __getattr__(name: str):
+    if name in _LAZY_ATTRS:
+        module_path, attr_name = _LAZY_ATTRS[name]
+        module = import_module(module_path, __name__)
+        value = getattr(module, attr_name)
+        globals()[name] = value
+        return value
+
+    try:
+        value = getattr(env_server, name)
+    except AttributeError as exc:
+        raise AttributeError(f"module {__name__!r} has no attribute {name!r}") from exc
+
+    globals()[name] = value
+    return value
+
+
+def __dir__() -> list[str]:
+    return sorted(set(globals().keys()) | set(__all__))