QuantPlatformKit/src/quant_platform_kit/data/__init__.py at 99ce27f418bef669b772c63bec44b5afa0130020 · QuantStrategyLab/QuantPlatformKit · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
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
92
93
94
95
"""Data version management — artifact versioning, manifest building, and release tracking.

Consolidates logic previously duplicated across UsEquitySnapshotPipelines,
HkEquitySnapshotPipelines, CnEquitySnapshotPipelines, and CryptoLivePoolPipelines.
"""

from quant_platform_kit.data.manifest import (
    build_artifact_record,
    write_artifact_manifest,
    write_data_release,
)
from quant_platform_kit.data.version import (
    DataVersion,
    latest_version,
    resolve_version,
    semver_version,
)
from quant_platform_kit.data.multisource_assurance import (
    DATA_ASSURANCE_STATUS_DEGRADED,
    DATA_ASSURANCE_STATUS_PARKED,
    DATA_ASSURANCE_STATUS_VERIFIED,
    MULTISOURCE_DAILY_BAR_ASSURANCE_SCHEMA_VERSION,
    SOURCE_OBSERVATION_INVALID,
    SOURCE_OBSERVATION_MISSING,
    SOURCE_OBSERVATION_READY,
    SOURCE_OBSERVATION_UNAVAILABLE,
    DailyBar,
    DailyBarSourceObservation,
    DailyBarSourceSnapshot,
    MultiSourceDailyBarAssurance,
    MultiSourceDailyBarPolicy,
    assess_multisource_daily_bars,
)
from quant_platform_kit.data.decision_data_binding import (
    DECISION_DATA_ASSURANCE_DEGRADED,
    DECISION_DATA_ASSURANCE_LEGACY,
    DECISION_DATA_ASSURANCE_PARKED,
    DECISION_DATA_ASSURANCE_VERIFIED,
    DECISION_DATA_BINDING_SCHEMA_VERSION,
    DECISION_DATA_MODE_ARTIFACT_OPTIONAL,
    DECISION_DATA_MODE_ARTIFACT_REQUIRED,
    DECISION_DATA_MODE_LEGACY_RUNTIME_FETCH,
    DecisionDataBinding,
)
from quant_platform_kit.data.decision_price_series_artifact import (
    DECISION_PRICE_SERIES_ARTIFACT_SCHEMA_VERSION,
    DECISION_PRICE_SERIES_MEMBER_PATH,
    InvalidDecisionDataArtifact,
    canonical_decision_price_series_artifact_bytes,
    price_series_from_decision_price_series_artifact,
    read_decision_price_series_artifact_json,
    validate_decision_price_series_artifact,
    verify_decision_price_series_artifact_members,
)

__all__ = [
    "DataVersion",
    "DECISION_DATA_ASSURANCE_DEGRADED",
    "DECISION_DATA_ASSURANCE_LEGACY",
    "DECISION_DATA_ASSURANCE_PARKED",
    "DECISION_DATA_ASSURANCE_VERIFIED",
    "DECISION_DATA_BINDING_SCHEMA_VERSION",
    "DECISION_DATA_MODE_ARTIFACT_OPTIONAL",
    "DECISION_DATA_MODE_ARTIFACT_REQUIRED",
    "DECISION_DATA_MODE_LEGACY_RUNTIME_FETCH",
    "DATA_ASSURANCE_STATUS_DEGRADED",
    "DATA_ASSURANCE_STATUS_PARKED",
    "DATA_ASSURANCE_STATUS_VERIFIED",
    "MULTISOURCE_DAILY_BAR_ASSURANCE_SCHEMA_VERSION",
    "SOURCE_OBSERVATION_INVALID",
    "SOURCE_OBSERVATION_MISSING",
    "SOURCE_OBSERVATION_READY",
    "SOURCE_OBSERVATION_UNAVAILABLE",
    "DailyBar",
    "DecisionDataBinding",
    "DECISION_PRICE_SERIES_ARTIFACT_SCHEMA_VERSION",
    "DECISION_PRICE_SERIES_MEMBER_PATH",
    "DailyBarSourceObservation",
    "DailyBarSourceSnapshot",
    "MultiSourceDailyBarAssurance",
    "MultiSourceDailyBarPolicy",
    "InvalidDecisionDataArtifact",
    "assess_multisource_daily_bars",
    "canonical_decision_price_series_artifact_bytes",
    "build_artifact_record",
    "latest_version",
    "price_series_from_decision_price_series_artifact",
    "read_decision_price_series_artifact_json",
    "resolve_version",
    "semver_version",
    "validate_decision_price_series_artifact",
    "verify_decision_price_series_artifact_members",
    "write_artifact_manifest",
    "write_data_release",
]