Skip to content

client.core

crp.sdk.proxies_more._CoreProxy

Core orchestrator and session primitives proxy.

Exposes the live orchestrator, its configuration, session handle, window DAG, manifest ledger, and LLM-in-the-loop facilitator.

Source code in crp/sdk/proxies_more.py 
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
class _CoreProxy:
    """Core orchestrator and session primitives proxy.

    Exposes the live orchestrator, its configuration, session handle, window
    DAG, manifest ledger, and LLM-in-the-loop facilitator.
    """

    def __init__(self, orchestrator: Any) -> None:
        self._orchestrator = orchestrator

    def orchestrator(self) -> Any:
        """Return the live ``CRPOrchestrator`` instance.

        Returns:
            CRPOrchestrator instance.
        """
        return self._orchestrator

    def config(self) -> Any:
        """Return the orchestrator's core configuration object.

        Returns:
            CRPConfig instance.
        """
        return getattr(self._orchestrator, "_config", None)

    def session(self) -> Any:
        """Return the current ``SessionHandle``.

        Returns:
            SessionHandle instance.
        """
        return getattr(self._orchestrator, "_session", None)

    def dag(self) -> Any:
        """Return a fresh ``WindowDAG`` instance.

        Returns:
            WindowDAG instance.
        """
        from crp.core.window import WindowDAG

        return WindowDAG()

    def ledger(self) -> Any:
        """Return a ``ManifestLedger`` bound to the current session.

        Returns:
            ManifestLedger instance.
        """
        from crp.core.manifest_ledger import ManifestLedger

        session_id = ""
        session = getattr(self._orchestrator, "_session", None)
        if session is not None:
            session_id = getattr(session, "session_id", "") or session_id
        return ManifestLedger(session_id=session_id)

    def facilitator(self) -> Any:
        """Return a ``CRPFacilitator`` wired to the orchestrator's provider.

        Returns:
            CRPFacilitator instance.
        """
        from crp.core.facilitator import CRPFacilitator

        return CRPFacilitator(
            provider=getattr(self._orchestrator, "_provider", None),
            warm_store=getattr(self._orchestrator, "warm_store", None),
        )

orchestrator()

Return the live CRPOrchestrator instance.

Returns:

Type Description
Any

CRPOrchestrator instance.
Source code in crp/sdk/proxies_more.py 
32
33
34
35
36
37
38
def orchestrator(self) -> Any:
    """Return the live ``CRPOrchestrator`` instance.

    Returns:
        CRPOrchestrator instance.
    """
    return self._orchestrator

config()

Return the orchestrator's core configuration object.

Returns:

Type Description
Any

CRPConfig instance.
Source code in crp/sdk/proxies_more.py 
40
41
42
43
44
45
46
def config(self) -> Any:
    """Return the orchestrator's core configuration object.

    Returns:
        CRPConfig instance.
    """
    return getattr(self._orchestrator, "_config", None)

session()

Return the current SessionHandle.

Returns:

Type Description
Any

SessionHandle instance.
Source code in crp/sdk/proxies_more.py 
48
49
50
51
52
53
54
def session(self) -> Any:
    """Return the current ``SessionHandle``.

    Returns:
        SessionHandle instance.
    """
    return getattr(self._orchestrator, "_session", None)

dag()

Return a fresh WindowDAG instance.

Returns:

Type Description
Any

WindowDAG instance.
Source code in crp/sdk/proxies_more.py 
56
57
58
59
60
61
62
63
64
def dag(self) -> Any:
    """Return a fresh ``WindowDAG`` instance.

    Returns:
        WindowDAG instance.
    """
    from crp.core.window import WindowDAG

    return WindowDAG()

ledger()

Return a ManifestLedger bound to the current session.

Returns:

Type Description
Any

ManifestLedger instance.
Source code in crp/sdk/proxies_more.py 
66
67
68
69
70
71
72
73
74
75
76
77
78
def ledger(self) -> Any:
    """Return a ``ManifestLedger`` bound to the current session.

    Returns:
        ManifestLedger instance.
    """
    from crp.core.manifest_ledger import ManifestLedger

    session_id = ""
    session = getattr(self._orchestrator, "_session", None)
    if session is not None:
        session_id = getattr(session, "session_id", "") or session_id
    return ManifestLedger(session_id=session_id)

facilitator()

Return a CRPFacilitator wired to the orchestrator's provider.

Returns:

Type Description
Any

CRPFacilitator instance.
Source code in crp/sdk/proxies_more.py 
80
81
82
83
84
85
86
87
88
89
90
91
def facilitator(self) -> Any:
    """Return a ``CRPFacilitator`` wired to the orchestrator's provider.

    Returns:
        CRPFacilitator instance.
    """
    from crp.core.facilitator import CRPFacilitator

    return CRPFacilitator(
        provider=getattr(self._orchestrator, "_provider", None),
        warm_store=getattr(self._orchestrator, "warm_store", None),
    )