Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/WackyGem/Fleur
/ types & classes
Types & classes
842 in github.com/WackyGem/Fleur
⨍
Functions
3,759
◇
Types & classes
842
↳
Endpoints
9
↓ 18 callers
Class
AssetStepSpec
pipeline/scheduler/src/scheduler/defs/automation/source_raw_backfill.py:357
↓ 18 callers
Class
BaostockProtocolError
Raised when a BaoStock message cannot be encoded or decoded.
pipeline/scheduler/src/scheduler/defs/baostock/protocol.py:25
↓ 17 callers
Class
BackfillPartitionSelection
pipeline/scheduler/src/scheduler/defs/automation/source_raw_backfill.py:160
↓ 17 callers
Class
FakeBaostockClientFactory
pipeline/scheduler/tests/fakes/baostock.py:133
↓ 17 callers
Class
HttpRequest
pipeline/scheduler/src/scheduler/defs/http/client.py:49
↓ 17 callers
Class
PostgresIndustryImageRepository
pipeline/scheduler/src/scheduler/defs/repositories/industry_images.py:276
↓ 16 callers
Class
BoundedTaskRunner
pipeline/scheduler/src/scheduler/defs/common/concurrency.py:76
↓ 16 callers
Class
FurnaceCliResource
pipeline/scheduler/src/scheduler/defs/resources/furnace.py:149
↓ 16 callers
Class
LintIssue
pipeline/elt/scripts/validate_field_glossary.py:19
↓ 14 callers
Class
S3SettingsResource
pipeline/scheduler/src/scheduler/defs/resources/s3.py:17
↓ 14 callers
Class
SchemaTypeError
Schema 类型转换失败。
pipeline/scheduler/src/scheduler/defs/common/types.py:13
↓ 12 callers
Class
BoundedTaskOptions
pipeline/scheduler/src/scheduler/defs/common/concurrency.py:13
↓ 12 callers
Class
ExponentialBackoffPolicy
Configurable exponential backoff schedule for transient remote failures.
pipeline/scheduler/src/scheduler/defs/common/retry.py:11
↓ 12 callers
Class
FakeAioHttpResponse
pipeline/scheduler/tests/fakes/http.py:23
↓ 12 callers
Class
MetricCatalog
engines/crates/rearview-core/src/domain/metric.rs:79
↓ 10 callers
Class
ChinabondRequestError
Raised when the ChinaBond response is structurally invalid.
pipeline/scheduler/src/scheduler/defs/sources/chinabond/client.py:15
↓ 10 callers
Class
MigrationCommand
pipeline/contract_tools/src/fleur_contracts/clickhouse_layer_migration.py:84
↓ 10 callers
Class
S3DatasetService
pipeline/scheduler/src/scheduler/defs/storage/dataset_service.py:54
↓ 9 callers
Class
AioHttpClient
pipeline/scheduler/src/scheduler/defs/http/client.py:170
↓ 9 callers
Class
DatasetLocation
pipeline/scheduler/src/scheduler/defs/storage/dataset_service.py:29
↓ 9 callers
Class
EastmoneyEndpointConfig
pipeline/scheduler/src/scheduler/defs/sources/eastmoney/schema.py:20
↓ 9 callers
Class
PassthroughModel
pipeline/elt/scripts/validate_f10_passthrough_coverage.py:17
↓ 9 callers
Class
ReadinessIssue
pipeline/elt/scripts/validate_staging_readiness.py:19
↓ 9 callers
Class
S3IOManager
pipeline/scheduler/src/scheduler/defs/io_managers/s3_io_manager.py:36
↓ 8 callers
Class
BackfillTargetSpec
pipeline/scheduler/src/scheduler/defs/automation/source_raw_backfill.py:349
↓ 8 callers
Class
FakeAioHttpSession
pipeline/scheduler/tests/fakes/http.py:57
↓ 8 callers
Class
Finding
scripts/validate_docs_governance.py:25
↓ 8 callers
Class
FurnaceKdjCliRequest
pipeline/scheduler/src/scheduler/defs/resources/furnace.py:18
↓ 8 callers
Class
RawSyncService
pipeline/scheduler/src/scheduler/defs/clickhouse/raw_sync.py:57
↓ 8 callers
Class
S3Config
pipeline/scheduler/src/scheduler/defs/config/models.py:26
↓ 7 callers
Class
BaostockAioTcpClient
pipeline/scheduler/src/scheduler/defs/baostock/client.py:82
↓ 7 callers
Class
BaostockNetworkError
Raised for TCP connection, send, receive, or timeout failures.
pipeline/scheduler/src/scheduler/defs/baostock/protocol.py:21
↓ 7 callers
Class
DescriptionQualityIssue
pipeline/contract_tools/src/fleur_contracts/description_quality.py:15
↓ 7 callers
Class
FakeClickHouseClient
pipeline/scheduler/tests/unit/clickhouse/test_raw_sync.py:21
↓ 7 callers
Class
FakeObjectStore
pipeline/scheduler/tests/unit/sources/jiuyan/test_industry_ocr_snapshot.py:41
↓ 7 callers
Class
FakeRepository
pipeline/scheduler/tests/unit/sources/jiuyan/test_industry_ocr_snapshot.py:29
↓ 7 callers
Class
OcrSchemaError
Raised when an OCR payload does not match the expected schema.
pipeline/scheduler/src/scheduler/defs/ocr/schemas.py:7
↓ 7 callers
Class
PartitionedParquetReadResult
pipeline/scheduler/src/scheduler/defs/storage/parquet_readers.py:20
↓ 7 callers
Class
QueryBlock
pipeline/elt/scripts/profile_raw_source.py:37
↓ 6 callers
Class
BackfillLimitPolicy
pipeline/scheduler/src/scheduler/defs/partitioning/policies.py:28
↓ 6 callers
Class
DatasetWriteResult
pipeline/scheduler/src/scheduler/defs/storage/dataset_writer.py:14
↓ 6 callers
Class
FactSpec
scripts/strategy_backtest_fact_snapshot.py:32
↓ 6 callers
Class
FakeAssetContext
pipeline/scheduler/tests/fakes/dagster.py:6
↓ 6 callers
Class
RoutingIssue
pipeline/elt/scripts/validate_layer_routing.py:27
↓ 6 callers
Class
SinaCalendarDecodeError
Raised when Sina's compact calendar payload cannot be decoded.
pipeline/scheduler/src/scheduler/defs/sources/sina/trade_calendar.py:47
↓ 6 callers
Class
SlackAlertResource
pipeline/scheduler/src/scheduler/defs/resources/slack.py:28
↓ 6 callers
Class
SourceBundle
pipeline/scheduler/src/scheduler/defs/source_bundle.py:10
↓ 6 callers
Class
_FakeAssetContext
pipeline/scheduler/tests/unit/baostock/test_baostock.py:1307
↓ 5 callers
Class
BackfillStepResult
pipeline/scheduler/src/scheduler/defs/automation/source_raw_backfill.py:252
↓ 5 callers
Class
BaostockResponse
pipeline/scheduler/src/scheduler/defs/baostock/protocol.py:51
↓ 5 callers
Class
DownstreamStageSpec
pipeline/scheduler/src/scheduler/defs/automation/source_to_marts_backfill.py:193
↓ 5 callers
Class
EastmoneyFetchedRow
pipeline/scheduler/src/scheduler/defs/sources/eastmoney/schema.py:40
↓ 5 callers
Class
EastmoneyRequestError
Raised when EastMoney returns an unrecoverable response.
pipeline/scheduler/src/scheduler/defs/sources/eastmoney/client.py:26
↓ 5 callers
Class
FailureThreshold
pipeline/scheduler/src/scheduler/defs/partitioning/policies.py:63
↓ 5 callers
Class
FakeJsonClient
pipeline/scheduler/tests/fakes/http.py:93
↓ 5 callers
Class
ObjectStore
pipeline/scheduler/src/scheduler/defs/storage/object_store.py:74
↓ 4 callers
Class
BackfillStep
pipeline/scheduler/src/scheduler/defs/automation/source_raw_backfill.py:185
↓ 4 callers
Class
BaostockAuthenticationError
Raised when BaoStock authentication fails or cannot be refreshed.
pipeline/scheduler/src/scheduler/defs/baostock/protocol.py:29
↓ 4 callers
Class
BaostockHistoryYearRangeBackfillConfig
pipeline/scheduler/src/scheduler/defs/baostock/backfill_controller.py:36
↓ 4 callers
Class
DatasetWriteOptions
pipeline/scheduler/src/scheduler/defs/storage/dataset_service.py:36
↓ 4 callers
Class
EastmoneyPage
pipeline/scheduler/src/scheduler/defs/sources/eastmoney/client.py:46
↓ 4 callers
Class
FakeBaostockAssetClient
pipeline/scheduler/tests/fakes/baostock.py:76
↓ 4 callers
Class
FakeClickHouseClient
pipeline/contract_tools/tests/test_clickhouse_layer_migration.py:33
↓ 4 callers
Class
FakeLog
pipeline/scheduler/tests/unit/daily/test_source_to_marts.py:484
↓ 4 callers
Class
FakeQueryResult
pipeline/scheduler/tests/unit/clickhouse/test_raw_sync.py:12
↓ 4 callers
Class
FakeRearviewApi
pipeline/scheduler/tests/unit/rearview/test_rearview_assets.py:24
↓ 4 callers
Class
FakeSubmitter
pipeline/scheduler/tests/unit/daily/test_source_to_marts.py:460
↓ 4 callers
Class
HttpFetchStats
pipeline/scheduler/src/scheduler/defs/http/client.py:72
↓ 4 callers
Class
HttpRequestError
Raised when an HTTP request fails permanently.
pipeline/scheduler/src/scheduler/defs/http/client.py:36
↓ 4 callers
Class
OcrSuccessUpdate
pipeline/scheduler/src/scheduler/defs/repositories/industry_images.py:254
↓ 4 callers
Class
PartialFailurePolicy
pipeline/scheduler/src/scheduler/defs/partitioning/policies.py:74
↓ 4 callers
Class
RearviewApiResource
HTTP client for Rearview control-plane APIs.
pipeline/scheduler/src/scheduler/defs/rearview/resources.py:13
↓ 4 callers
Class
SinaCalendarParseResult
pipeline/scheduler/src/scheduler/defs/sources/sina/trade_calendar.py:177
↓ 3 callers
Class
BackfillCommand
pipeline/scheduler/src/scheduler/defs/baostock/backfill_controller.py:45
↓ 3 callers
Class
BackfillControllerRequest
pipeline/scheduler/src/scheduler/defs/automation/source_raw_backfill.py:86
↓ 3 callers
Class
BaostockClientConfig
pipeline/scheduler/src/scheduler/defs/config/models.py:44
↓ 3 callers
Class
Completed
pipeline/contract_tools/tests/test_clickhouse_layer_migration.py:231
↓ 3 callers
Class
EastmoneyAioHttpClient
pipeline/scheduler/src/scheduler/defs/sources/eastmoney/client.py:52
↓ 3 callers
Class
FailureMessageInput
pipeline/scheduler/src/scheduler/defs/automation/slack_alerts.py:22
↓ 3 callers
Class
FurnaceBollCliRequest
pipeline/scheduler/src/scheduler/defs/resources/furnace.py:83
↓ 3 callers
Class
FurnaceMaCliRequest
pipeline/scheduler/src/scheduler/defs/resources/furnace.py:39
↓ 3 callers
Class
FurnacePricePatternCliRequest
pipeline/scheduler/src/scheduler/defs/resources/furnace.py:125
↓ 3 callers
Class
FurnaceRsiCliRequest
pipeline/scheduler/src/scheduler/defs/resources/furnace.py:62
↓ 3 callers
Class
InProcessDagsterRunSubmitter
pipeline/scheduler/src/scheduler/defs/automation/source_raw_backfill.py:272
↓ 3 callers
Class
SinaCalendarParser
Parse Sina's compact A-share trade-calendar payload.
pipeline/scheduler/src/scheduler/defs/sources/sina/trade_calendar.py:190
↓ 3 callers
Class
SourceToMartsControllerRequest
pipeline/scheduler/src/scheduler/defs/automation/source_to_marts_backfill.py:80
↓ 3 callers
Class
TableConversionResult
pipeline/scheduler/src/scheduler/defs/http/schemas.py:51
↓ 2 callers
Class
AssetJobSpec
pipeline/scheduler/src/scheduler/defs/automation/schedules.py:11
↓ 2 callers
Class
BaostockClientFactoryResource
pipeline/scheduler/src/scheduler/defs/resources/baostock.py:22
↓ 2 callers
Class
ClickHouseConfig
pipeline/scheduler/src/scheduler/defs/config/models.py:93
↓ 2 callers
Class
ContractRegistry
pipeline/contract_tools/src/fleur_contracts/schema.py:180
↓ 2 callers
Class
DailyFetchHistorySourcesToMartsRequest
pipeline/scheduler/src/scheduler/defs/daily/source_to_marts.py:46
↓ 2 callers
Class
DailyPortfolioNavLiquidationConfig
pipeline/scheduler/src/scheduler/defs/rearview/assets.py:20
↓ 2 callers
Class
DailyStep
pipeline/scheduler/src/scheduler/defs/daily/source_to_marts.py:104
↓ 2 callers
Class
DatasetPartitionWriteError
pipeline/scheduler/src/scheduler/defs/storage/dataset_writer.py:36
↓ 2 callers
Class
DownloadFailureUpdate
pipeline/scheduler/src/scheduler/defs/repositories/industry_images.py:247
↓ 2 callers
Class
DownloadSuccessUpdate
pipeline/scheduler/src/scheduler/defs/repositories/industry_images.py:239
↓ 2 callers
Class
DuplicateRowTracker
pipeline/scheduler/src/scheduler/defs/http/pagination.py:9
↓ 2 callers
Class
ExamplePortfolioLiveRunConfig
pipeline/scheduler/src/scheduler/defs/rearview/assets.py:26
↓ 2 callers
Class
FakeDailyNavRearviewApi
pipeline/scheduler/tests/unit/rearview/test_rearview_assets.py:41
next →
1–100 of 842, ranked by callers