MCPcopy Create free account

hub / github.com/WackyGem/Fleur / functions

Functions3,759 in github.com/WackyGem/Fleur

⨍ Functions 3,759◇ Types & classes 842↳ Endpoints 9
↓ 2 callersFunction_parquet_object_key
(dataset: DatasetContract, partition_key: str | None = None)
pipeline/contract_tools/src/fleur_contracts/clickhouse_layer_migration.py:1344
↓ 2 callersFunction_parse_date
(value: str, *, field_name: str)
pipeline/scheduler/src/scheduler/defs/automation/source_raw_backfill.py:935
↓ 2 callersFunction_parse_date
(value: str, *, field_name: str)
pipeline/scheduler/src/scheduler/defs/automation/source_to_marts_backfill.py:552
↓ 2 callersFunction_parse_date_partition_key
(partition_key: str)
pipeline/scheduler/src/scheduler/defs/http/partitioning.py:288
↓ 2 callersFunction_parse_int
(value: str, field_name: str)
pipeline/scheduler/src/scheduler/defs/baostock/protocol.py:274
↓ 2 callersFunction_parse_int
(value: str)
pipeline/elt/scripts/profile_raw_source.py:714
↓ 2 callersFunction_partition_start_date
(partition_key: str)
pipeline/scheduler/src/scheduler/defs/sources/chinabond/services.py:281
↓ 2 callersFunction_payload_api_name
(payload: bytes)
pipeline/scheduler/tests/unit/baostock/test_baostock.py:1379
↓ 2 callersMethod_prepare_staging
(self, spec: ClickHouseRawTableSpec)
pipeline/scheduler/src/scheduler/defs/clickhouse/raw_sync.py:174
↓ 2 callersMethod_query_paginated
( self, request_code: str, api_name: str, params: list[str], *,
pipeline/scheduler/src/scheduler/defs/baostock/client.py:213
↓ 2 callersFunction_raise_for_kline_request_failures
( runner_result: BoundedTaskResult[pa.Table], )
pipeline/scheduler/src/scheduler/defs/baostock/services.py:359
↓ 2 callersFunction_raw_datasets
(datasets: Sequence[DatasetContract])
pipeline/contract_tools/src/fleur_contracts/clickhouse_layer_migration.py:1159
↓ 2 callersMethod_request_json
( self, url: str, params: Mapping[str, str], )
pipeline/scheduler/src/scheduler/defs/sources/eastmoney/client.py:168
↓ 2 callersFunction_required_date
(value: date | None, *, field_name: str)
pipeline/scheduler/src/scheduler/defs/automation/source_to_marts_backfill.py:640
↓ 2 callersFunction_required_env
(name: str)
pipeline/contract_tools/src/fleur_contracts/validate_clickhouse.py:105
↓ 2 callersFunction_resolve_required_env_value
(value: str | dg.EnvVar, *, field_name: str)
pipeline/scheduler/src/scheduler/defs/resources/slack.py:20
↓ 2 callersMethod_resolved_base_url
(self)
pipeline/scheduler/src/scheduler/defs/rearview/resources.py:134
↓ 2 callersFunction_schema_fingerprint
( client: ClickHouseMigrationClient, database: str, table: str, )
pipeline/contract_tools/src/fleur_contracts/clickhouse_layer_migration.py:1364
↓ 2 callersFunction_selected_target_names
()
pipeline/migrate/env.py:77
↓ 2 callersFunction_single_asset_key
(asset: dg.AssetsDefinition)
pipeline/scheduler/src/scheduler/defs/automation/source_to_marts_backfill.py:647
↓ 2 callersFunction_source_location
(*, bucket: str, asset_key: dg.AssetKey)
pipeline/scheduler/src/scheduler/defs/market/readers.py:77
↓ 2 callersFunction_source_only_payload
()
pipeline/contract_tools/tests/test_contract_registry.py:182
↓ 2 callersFunction_split_markdown_table_row
(line: str)
pipeline/elt/scripts/profile_raw_source.py:666
↓ 2 callersFunction_state_service_from_repository
( repository: PostgresIndustryImageRepository | None, )
pipeline/scheduler/src/scheduler/defs/sources/jiuyan/ocr_services.py:219
↓ 2 callersFunction_step_tags
( common_tags: Mapping[str, str], *, stage: str, step_kind: str, source_step_tags: Mapping
pipeline/scheduler/src/scheduler/defs/automation/source_to_marts_backfill.py:597
↓ 2 callersFunction_step_tags
( *, source_tags: Mapping[str, str], common_tags: Mapping[str, str], stage: str, step_kind
pipeline/scheduler/src/scheduler/defs/daily/source_to_marts.py:470
↓ 2 callersFunction_string_candidates
(value: object)
pipeline/scheduler/src/scheduler/defs/sources/jiuyan/image_urls.py:61
↓ 2 callersMethod_sync_http_stats
(self)
pipeline/scheduler/src/scheduler/defs/sources/eastmoney/client.py:189
↓ 2 callersFunction_table_exists
(client: ClickHouseMigrationClient, database: str, table: str)
pipeline/contract_tools/src/fleur_contracts/clickhouse_layer_migration.py:1414
↓ 2 callersFunction_uses_flat_model_asset_key
(dbt_resource_props: Mapping[str, Any])
pipeline/scheduler/src/scheduler/components/fleur_dbt.py:30
↓ 2 callersFunction_validate_expected_columns
( table: pa.Table, expected_columns: list[str], api_name: str, )
pipeline/scheduler/src/scheduler/defs/baostock/schemas.py:89
↓ 2 callersMethod_validate_low_cardinality_columns
(self, spec: ClickHouseRawTableSpec)
pipeline/scheduler/src/scheduler/defs/clickhouse/raw_sync.py:250
↓ 2 callersMethod_validate_schema
(self, spec: ClickHouseRawTableSpec)
pipeline/scheduler/src/scheduler/defs/clickhouse/raw_sync.py:213
↓ 2 callersFunction_validate_source_columns
( *, model_name: str, column_name: str, meta: Mapping[str, Any], raw_columns: set[tuple[st
pipeline/elt/scripts/validate_field_glossary.py:330
↓ 2 callersFunction_year_source_to_raw_step_specs
( *, label_prefix: str, source_asset_keys: tuple[str, ...], raw_asset_keys: tuple[str, ...],
pipeline/scheduler/src/scheduler/defs/automation/source_raw_backfill.py:728
↓ 2 callersFunctionacceptStrategyBacktestRunForStep5
( run: StrategyBacktestRunRecord )
app/racingline/src/features/strategy/backtest.ts:8
↓ 2 callersFunctionaccount_template_from_row
(row: &sqlx::postgres::PgRow)
engines/crates/rearview-core/src/postgres/mod.rs:3913
↓ 2 callersFunctionadd_controller_run_tags
( tag_writer: RunTagWriter, *, run_id: str, plan: BackfillPlan, )
pipeline/scheduler/src/scheduler/defs/automation/source_raw_backfill.py:339
↓ 2 callersFunctionadd_daily_fetch_history_sources_to_marts_controller_run_tags
( tag_writer: RunTagWriter, *, run_id: str, plan: DailyPlan, )
pipeline/scheduler/src/scheduler/defs/daily/source_to_marts.py:278
↓ 2 callersFunctionadd_source_to_marts_controller_run_tags
( tag_writer: RunTagWriter, *, run_id: str, plan: SourceToMartsPlan, )
pipeline/scheduler/src/scheduler/defs/automation/source_to_marts_backfill.py:292
↓ 2 callersFunctionall_registered_raw_asset_keys
()
pipeline/scheduler/src/scheduler/defs/automation/source_raw_backfill.py:464
↓ 2 callersFunctionall_registered_source_asset_keys
()
pipeline/scheduler/src/scheduler/defs/automation/source_raw_backfill.py:460
↓ 2 callersFunctionapiBaseUrl
()
app/racingline/src/api/client.ts:29
↓ 2 callersMethodapi_names_by_connection
(self)
pipeline/scheduler/tests/unit/baostock/test_baostock.py:1372
↓ 2 callersFunctionarchiveStrategyPortfolio
(strategyPortfolioId: string)
app/racingline/src/api/rearview.ts:348
↓ 2 callersFunctionareTransactionFeesEqual
( left: SimulationSettings["transactionFees"], right: SimulationSettings["transactionFees"] )
app/racingline/src/features/strategy/execution.ts:55
↓ 2 callersFunctionassertMetricAllowedForCapability
( metric: MetricDefinition, operator: Operator, capability: MetricCapability, itemId: string | undefin
app/racingline/src/features/strategy/adapters.ts:693
↓ 2 callersMethodassert_operator_allowed
(&self, operator: Operator)
engines/crates/rearview-core/src/domain/metric.rs:146
↓ 2 callersFunctionasset_keys
(asset: dg.AssetsDefinition)
pipeline/scheduler/tests/integration/test_definitions_and_schedules.py:41
↓ 2 callersFunctionaverage
(values: &[f64])
engines/crates/rearview-core/src/portfolio_trade_metrics.rs:218
↓ 2 callersFunctionaverage_required
(output: &MaOutput, windows: &[usize])
engines/crates/furnace-core/src/indicators/moving_average.rs:495
↓ 2 callersMethodbase_url
(&self)
engines/crates/rearview-core/src/config.rs:121
↓ 2 callersFunctionbenchmark_latest_trade_date_sql
(quoted_database: &str, quoted_security_code: &str)
engines/crates/rearview-core/src/clickhouse/mod.rs:3829
↓ 2 callersFunctionbuildBacktestPerformanceGroups
( performance: | StrategyBacktestPerformanceUiView | StrategyBacktestPerformanceView | null, l
app/racingline/src/routes/strategy-page.tsx:1313
↓ 2 callersFunctionbuildGroupFilterNode
( group: StrategyConditionGroup, metricIndex: MetricIndex )
app/racingline/src/features/strategy/adapters.ts:476
↓ 2 callersFunctionbuildMetricLabels
(metrics: MetricDefinition[])
app/racingline/src/features/strategy/preview.ts:237
↓ 2 callersFunctionbuildMixedLogicFilterNode
( groupId: string, conditions: StrategyCondition[], metricIndex: MetricIndex )
app/racingline/src/features/strategy/adapters.ts:487
↓ 2 callersFunctionbuildPreviewStockRow
( signal: StrategyPreviewSignal, labels: PreviewSnapshot["labels"] )
app/racingline/src/features/strategy/preview.ts:200
↓ 2 callersFunctionbuildPreviewTimelineRange
( now = new Date(), previewRowLimit = 10 )
app/racingline/src/features/strategy/preview.ts:134
↓ 2 callersFunctionbuildStrategyCatalog
( metrics: MetricDefinition[], capability: MetricCapability )
app/racingline/src/features/strategy/adapters.ts:125
↓ 2 callersFunctionbuildStrategyConfigDisplayFromCanonical
({ executionConfig, metricCatalogs = [], rule, }: { executionConfig: BacktestExecutionConfig metricC
app/racingline/src/features/strategy/config-display.ts:98
↓ 2 callersFunctionbuildStrategyConfigDisplayFromDraft
({ conditionCatalogOptions, conditionGroups, scoringCatalogOptions, settings, weightIndicators, }: {
app/racingline/src/features/strategy/config-display.ts:60
↓ 2 callersFunctionbuildStrategyConfigSourceContext
({ benchmark_security_code, live_start_date, source_end_date, source_period_key, source_start_date,
app/racingline/src/features/strategy/config-display.ts:154
↓ 2 callersFunctionbuild_asset_job
(spec: AssetJobSpec)
pipeline/scheduler/src/scheduler/defs/automation/schedules.py:28
↓ 2 callersFunctionbuild_client_from_env
(*, database: str | None = None)
pipeline/contract_tools/src/fleur_contracts/validate_clickhouse.py:79
↓ 2 callersMethodbuild_defs
(self, context: dg.ComponentLoadContext)
pipeline/scheduler/src/scheduler/components/furnace.py:14
↓ 2 callersFunctionbuild_ocr_request_payload
(model_name: str, image_data_url: str)
pipeline/scheduler/src/scheduler/defs/sources/jiuyan/ocr_client.py:57
↓ 2 callersFunctionbuild_portfolio_code
(now: DateTime<Utc>, entropy: ulid::Ulid)
engines/crates/rearview-core/src/strategy_portfolio.rs:14
↓ 2 callersFunctionbuild_preview_chart_context_response
( input: PreviewChartContextBuildInput, selected_quote: Option<QuoteMartRow>, quote_rows: Vec<Quot
engines/crates/rearview-core/src/api/mod.rs:7173
↓ 2 callersFunctionbuild_schedule
(spec: ScheduleSpec)
pipeline/scheduler/src/scheduler/defs/automation/schedules.py:32
↓ 2 callersFunctionbuttonElement
(label: string)
app/racingline/src/routes/strategy-detail-page.test.tsx:453
↓ 2 callersFunctioncalculate_boll_grouped_outputs_parallel_with_collection
( request: &BollRunRequest, effective_output_to: &str, groups: &[BollGroupedInput], collect_ro
engines/crates/furnace-io/src/runners/boll/materialize.rs:80
↓ 2 callersFunctioncalculate_boll_grouped_outputs_serial_with_collection
( request: &BollRunRequest, effective_output_to: &str, groups: &[BollGroupedInput], collect_ro
engines/crates/furnace-io/src/runners/boll/materialize.rs:54
↓ 2 callersFunctioncalculate_boll_security_outputs
( request: &BollRunRequest, effective_output_to: &str, group: &BollGroupedInput, collect_rows:
engines/crates/furnace-io/src/runners/boll/materialize.rs:110
↓ 2 callersFunctioncalculate_grouped_outputs_parallel_with_collection
( request: &KdjRunRequest, effective_output_to: &str, groups: &[KdjGroupedInput], states: &Has
engines/crates/furnace-io/src/runners/kdj/materialize.rs:113
↓ 2 callersFunctioncalculate_grouped_outputs_serial_with_collection
( request: &KdjRunRequest, effective_output_to: &str, groups: &[KdjGroupedInput], states: &Has
engines/crates/furnace-io/src/runners/kdj/materialize.rs:72
↓ 2 callersFunctioncalculate_ma_grouped_outputs_parallel_with_collection
( request: &MaRunRequest, effective_output_to: &str, groups: &[MaGroupedInput], states: &HashM
engines/crates/furnace-io/src/runners/ma/materialize.rs:92
↓ 2 callersFunctioncalculate_ma_grouped_outputs_serial_with_collection
( request: &MaRunRequest, effective_output_to: &str, groups: &[MaGroupedInput], states: &HashM
engines/crates/furnace-io/src/runners/ma/materialize.rs:57
↓ 2 callersFunctioncalculate_ma_security_outputs
( request: &MaRunRequest, effective_output_to: &str, states: &HashMap<String, MaPreviousState>,
engines/crates/furnace-io/src/runners/ma/materialize.rs:125
↓ 2 callersFunctioncalculate_ma_series_from_previous_state
为单只证券的有序时间序列计算 Moving Average 输出，并从指定日期后的行延续 EMA 状态。 SMA 会消费全部输入行；EMA 在 `previous_state.trade_date` 及之前不推进， 从之后的有效 close 开始按上一状态递推。 # 错误 当参数无效、价格无效
engines/crates/furnace-core/src/indicators/moving_average.rs:351
↓ 2 callersFunctioncalculate_ma_series_internal
( inputs: &[MaInput], params: &MaParams, previous_state: Option<MaState>, previous_state_date:
engines/crates/furnace-core/src/indicators/moving_average.rs:363
↓ 2 callersFunctioncalculate_macd_grouped_outputs_parallel_with_collection
( request: &MacdRunRequest, effective_output_to: &str, groups: &[MacdGroupedInput], states: &H
engines/crates/furnace-io/src/runners/macd/materialize.rs:180
↓ 2 callersFunctioncalculate_macd_grouped_outputs_serial_with_collection
( request: &MacdRunRequest, effective_output_to: &str, groups: &[MacdGroupedInput], states: &H
engines/crates/furnace-io/src/runners/macd/materialize.rs:148
↓ 2 callersFunctioncalculate_macd_security_outputs
( request: &MacdRunRequest, effective_output_to: &str, states: &HashMap<String, MacdPreviousState>
engines/crates/furnace-io/src/runners/macd/materialize.rs:217
↓ 2 callersFunctioncalculate_macd_series_from_previous_state
Calculate MACD outputs, skipping rows up to the dated previous state. # Errors Returns an error when parameters are invalid, input prices are invali
engines/crates/furnace-core/src/indicators/macd.rs:261
↓ 2 callersFunctioncalculate_price_pattern_grouped_outputs_parallel_with_collection
( request: &PricePatternRunRequest, effective_output_to: &str, groups: &[PricePatternGroupedInput]
engines/crates/furnace-io/src/runners/price_pattern/materialize.rs:95
↓ 2 callersFunctioncalculate_price_pattern_grouped_outputs_serial_with_collection
( request: &PricePatternRunRequest, effective_output_to: &str, groups: &[PricePatternGroupedInput]
engines/crates/furnace-io/src/runners/price_pattern/materialize.rs:59
↓ 2 callersFunctioncalculate_price_pattern_security_outputs
( request: &PricePatternRunRequest, effective_output_to: &str, group: &PricePatternGroupedInput,
engines/crates/furnace-io/src/runners/price_pattern/materialize.rs:136
↓ 2 callersFunctioncalculate_rsi_grouped_outputs_parallel_with_collection
( request: &RsiRunRequest, effective_output_to: &str, groups: &[RsiGroupedInput], states: &Has
engines/crates/furnace-io/src/runners/rsi/materialize.rs:88
↓ 2 callersFunctioncalculate_rsi_grouped_outputs_serial_with_collection
( request: &RsiRunRequest, effective_output_to: &str, groups: &[RsiGroupedInput], states: &Has
engines/crates/furnace-io/src/runners/rsi/materialize.rs:56
↓ 2 callersFunctioncalculate_rsi_security_outputs
( request: &RsiRunRequest, effective_output_to: &str, states: &HashMap<String, RsiPreviousState>,
engines/crates/furnace-io/src/runners/rsi/materialize.rs:125
↓ 2 callersFunctioncalculate_rsi_series_internal
( inputs: &[RsiInput], params: &RsiParams, previous_state: Option<RsiState>, previous_state_da
engines/crates/furnace-core/src/indicators/rsi.rs:377
↓ 2 callersFunctioncalculate_security_outputs
( request: &KdjRunRequest, effective_output_to: &str, states: &HashMap<String, KdjState>, grou
engines/crates/furnace-io/src/runners/kdj/materialize.rs:141
↓ 2 callersFunctioncalculate_sma_seeded_ema_series
计算一组输入的 SMA 启动 EMA 序列。 # 错误 当窗口非法、状态非法或输入包含非有限数时返回错误。
engines/crates/furnace-core/src/operators/ema.rs:115
↓ 2 callersFunctioncalculation_asset_keys_covered_by_all_source_to_marts_scope
()
pipeline/scheduler/src/scheduler/defs/automation/source_to_marts_backfill.py:311
↓ 2 callersMethodchannel
(self)
pipeline/scheduler/src/scheduler/defs/resources/slack.py:39
↓ 2 callersFunctionchartTimeToDateKey
(time: unknown)
app/racingline/src/routes/strategy-detail-page.tsx:1818
↓ 2 callersFunctionchart_context_chart_quote_select_columns
(adjustment: AnalysisQuoteAdjustment)
engines/crates/rearview-core/src/clickhouse/mod.rs:3950
↓ 2 callersFunctionchart_context_selected_quote_select_columns
()
engines/crates/rearview-core/src/clickhouse/mod.rs:3982
↓ 2 callersFunctionchart_context_trend_select_columns
()
engines/crates/rearview-core/src/clickhouse/mod.rs:4021
← previousnext →701–800 of 3,759, ranked by callers