Skip to content

refactor(torghut): normalize scheduler pipeline modules #10870

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
gregkonush merged 2 commits into from
Jun 14, 2026
Merged

refactor(torghut): normalize scheduler pipeline modules #10870

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
398f734
refactor(torghut): normalize scheduler pipeline modules
gregkonush Jun 14, 2026
e3e0b5b
fix(torghut): preserve llm review persistence call shape
gregkonush Jun 14, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 4 additions & 11 deletions services/torghut/app/trading/scheduler/pipeline.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,14 +1,7 @@
# pyright: reportMissingImports=false, reportUnknownVariableType=false, reportUnknownMemberType=false, reportUnknownArgumentType=false, reportUnknownParameterType=false, reportUnknownLambdaType=false, reportUnusedImport=false, reportUnusedClass=false, reportUnusedFunction=false, reportUnusedVariable=false, reportUndefinedVariable=false, reportUnsupportedDunderAll=false, reportAttributeAccessIssue=false, reportUntypedBaseClass=false, reportGeneralTypeIssues=false, reportInvalidTypeForm=false, reportReturnType=false, reportOptionalMemberAccess=false, reportArgumentType=false, reportCallIssue=false, reportPrivateUsage=false
"""Public trading pipeline import surface."""

from __future__ import annotations

from importlib import import_module as _import_module
import sys as _sys
from .pipeline_modules import TradingPipeline

_module_name = __name__
_parent_name, _, _module_attr = _module_name.rpartition(".")
_impl = _import_module("app.trading.scheduler.pipeline_modules")
globals().update(_impl.__dict__)
_sys.modules[_module_name] = _impl
_parent = _sys.modules.get(_parent_name)
if _parent is not None:
setattr(_parent, _module_attr, _impl)
__all__ = ["TradingPipeline"]
136 changes: 20 additions & 116 deletions services/torghut/app/trading/scheduler/pipeline_modules/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,121 +1,25 @@
# pyright: reportMissingImports=false, reportUnknownVariableType=false, reportUnknownMemberType=false, reportUnknownArgumentType=false, reportUnknownParameterType=false, reportUnknownLambdaType=false, reportUnusedImport=false, reportUnusedClass=false, reportUnusedFunction=false, reportUnusedVariable=false, reportUndefinedVariable=false, reportUnsupportedDunderAll=false, reportAttributeAccessIssue=false, reportUntypedBaseClass=false, reportGeneralTypeIssues=false, reportInvalidTypeForm=false, reportReturnType=false, reportOptionalMemberAccess=false, reportArgumentType=false, reportCallIssue=false, reportPrivateUsage=false, reportUnnecessaryComparison=false, reportMissingTypeStubs=false, reportUnnecessaryCast=false
from __future__ import annotations

from importlib import import_module as __compat_import_module__
import logging as __compat_logging__
import sys as __compat_sys__
import types as __compat_types__

__compat_part_modules__: list[__compat_types__.ModuleType] = []


class __CompatModule__(__compat_types__.ModuleType):
def __setattr__(self, name: str, value: object) -> None:
super().__setattr__(name, value)
for module in __compat_part_modules__:
module.__dict__[name] = value


def __compat_export__(module: __compat_types__.ModuleType) -> None:
for name, value in module.__dict__.items():
if name.startswith("__"):
continue
globals()[name] = value

"""Semantic modules for the trading scheduler pipeline."""

__compat_module__ = __compat_import_module__(f"{__name__}.part_01_statements_158")
__compat_part_modules__.append(__compat_module__)
__compat_export__(__compat_module__)
for __compat_loaded_module__ in __compat_part_modules__:
__compat_loaded_module__.__dict__.update(
{name: value for name, value in globals().items() if not name.startswith("__")}
)

__compat_module__ = __compat_import_module__(
f"{__name__}.part_02_tradingpipelinemethodspart1"
)
__compat_part_modules__.append(__compat_module__)
__compat_export__(__compat_module__)
for __compat_loaded_module__ in __compat_part_modules__:
__compat_loaded_module__.__dict__.update(
{name: value for name, value in globals().items() if not name.startswith("__")}
)

__compat_module__ = __compat_import_module__(
f"{__name__}.part_03_tradingpipelinemethodspart2"
)
__compat_part_modules__.append(__compat_module__)
__compat_export__(__compat_module__)
for __compat_loaded_module__ in __compat_part_modules__:
__compat_loaded_module__.__dict__.update(
{name: value for name, value in globals().items() if not name.startswith("__")}
)

__compat_module__ = __compat_import_module__(
f"{__name__}.part_04_tradingpipelinemethodspart3"
)
__compat_part_modules__.append(__compat_module__)
__compat_export__(__compat_module__)
for __compat_loaded_module__ in __compat_part_modules__:
__compat_loaded_module__.__dict__.update(
{name: value for name, value in globals().items() if not name.startswith("__")}
)

__compat_module__ = __compat_import_module__(
f"{__name__}.part_05_tradingpipelinemethodspart4"
)
__compat_part_modules__.append(__compat_module__)
__compat_export__(__compat_module__)
for __compat_loaded_module__ in __compat_part_modules__:
__compat_loaded_module__.__dict__.update(
{name: value for name, value in globals().items() if not name.startswith("__")}
)

__compat_module__ = __compat_import_module__(
f"{__name__}.part_06_tradingpipelinemethodspart5"
)
__compat_part_modules__.append(__compat_module__)
__compat_export__(__compat_module__)
for __compat_loaded_module__ in __compat_part_modules__:
__compat_loaded_module__.__dict__.update(
{name: value for name, value in globals().items() if not name.startswith("__")}
)

__compat_module__ = __compat_import_module__(
f"{__name__}.part_07_tradingpipelinemethodspart6"
)
__compat_part_modules__.append(__compat_module__)
__compat_export__(__compat_module__)
for __compat_loaded_module__ in __compat_part_modules__:
__compat_loaded_module__.__dict__.update(
{name: value for name, value in globals().items() if not name.startswith("__")}
)

__compat_module__ = __compat_import_module__(
f"{__name__}.part_08_tradingpipelinemethodspart7"
)
__compat_part_modules__.append(__compat_module__)
__compat_export__(__compat_module__)
for __compat_loaded_module__ in __compat_part_modules__:
__compat_loaded_module__.__dict__.update(
{name: value for name, value in globals().items() if not name.startswith("__")}
)
from __future__ import annotations

__compat_module__ = __compat_import_module__(f"{__name__}.part_09_tradingpipeline")
__compat_part_modules__.append(__compat_module__)
__compat_export__(__compat_module__)
for __compat_loaded_module__ in __compat_part_modules__:
__compat_loaded_module__.__dict__.update(
{name: value for name, value in globals().items() if not name.startswith("__")}
)
from .decision_lifecycle import TradingPipelineDecisionLifecycleMixin
from .llm_outcomes import TradingPipelineReviewOutcomeMixin
from .llm_review import TradingPipelineReviewMixin
from .run_cycle import TradingPipelineRunCycleMixin
from .runtime_gates import TradingPipelineRuntimeGatesMixin
from .shared import TradingPipelineBase
from .signal_processing import TradingPipelineSignalProcessingMixin
from .submission_policy import TradingPipelineSubmissionPolicyMixin
from .trading_pipeline import TradingPipeline

__compat_sys__.modules[__name__].__class__ = __CompatModule__
logger = __compat_logging__.getLogger(__name__.removesuffix("_modules"))
for __compat_loaded_module__ in globals().get("__compat_part_modules__", ()):
__compat_loaded_module__.__dict__["logger"] = logger
__all__ = [
name
for name in globals()
if not name.startswith("__") and not name.startswith("_CompatModule")
"TradingPipeline",
"TradingPipelineBase",
"TradingPipelineDecisionLifecycleMixin",
"TradingPipelineReviewMixin",
"TradingPipelineReviewOutcomeMixin",
"TradingPipelineRunCycleMixin",
"TradingPipelineRuntimeGatesMixin",
"TradingPipelineSignalProcessingMixin",
"TradingPipelineSubmissionPolicyMixin",
]
del __compat_module__
Loading
Loading