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
↓ 6 callersFunction_format_list
(values: list[str])
pipeline/elt/scripts/profile_raw_source.py:736
↓ 6 callersFunction_load_profile_module
()
pipeline/contract_tools/tests/test_profile_raw_source.py:11
↓ 6 callersMethod_parse_summary
(stdout: str)
pipeline/scheduler/src/scheduler/defs/resources/furnace.py:528
↓ 6 callersFunction_quote_identifier
(name: str)
pipeline/elt/scripts/profile_raw_source.py:725
↓ 6 callersFunction_raw_contract
()
pipeline/contract_tools/tests/test_contract_registry.py:222
↓ 6 callersMethod_resolved_binary_path
(self)
pipeline/scheduler/src/scheduler/defs/resources/furnace.py:501
↓ 6 callersMethod_subprocess_env
(self)
pipeline/scheduler/src/scheduler/defs/resources/furnace.py:521
↓ 6 callersFunctionaffected_years
(from: &str, to: &str)
engines/crates/furnace-io/src/validation.rs:4
↓ 6 callersMethodapply_flag
( &mut self, flag: &str, value: String, parse_mode: impl FnOnce(&str) -> Resul
engines/crates/furnace/src/commands/common.rs:39
↓ 6 callersFunctionasset_key
(asset: dg.AssetsDefinition)
pipeline/scheduler/tests/integration/test_definitions_and_schedules.py:37
↓ 6 callersFunctionbuildStrategyBacktestValidateRequest
({ marketTemplate, previewSnapshot, settings, }: { marketTemplate: MarketFeeTemplateRecord previewSn
app/racingline/src/features/strategy/execution.ts:140
↓ 6 callersFunctioncleanup_staging
( executor: &mut E, drop_sql: &str, )
engines/crates/furnace-io/src/runners/shared/writing.rs:170
↓ 6 callersFunctionclickButton
(label: string)
app/racingline/src/routes/strategy-detail-page.test.tsx:471
↓ 6 callersFunctionclient_config
(max_connections: int = 2)
pipeline/scheduler/tests/fakes/baostock.py:66
↓ 6 callersMethodclose
(self)
pipeline/contract_tools/src/fleur_contracts/clickhouse_layer_migration.py:57
↓ 6 callersMethodcompile_explain
(&self, rule: &RuleVersionSpec)
engines/crates/rearview-core/src/planner/sql.rs:48
↓ 6 callersFunctioncreate_staging_table_sql
构造 staging 表创建 SQL，表结构与目标表一致。
engines/crates/furnace-io/src/schema/staging.rs:59
↓ 6 callersMethoddelays
(self, max_attempts: int)
pipeline/scheduler/src/scheduler/defs/common/retry.py:21
↓ 6 callersFunctiondrop_staging_table_sql
构造删除临时 staging 表的 SQL。
engines/crates/furnace-io/src/schema/staging.rs:101
↓ 6 callersFunctionelapsed_seconds
(started_at: float)
pipeline/scheduler/src/scheduler/defs/clickhouse/raw_sync.py:268
↓ 6 callersFunctionensure_output_schema
( executor: &mut E, output_table_sql: &str, )
engines/crates/furnace-io/src/runners/shared/writing.rs:16
↓ 6 callersFunctionensure_production_output_rows
( indicator: &str, writes_applied: bool, output_is_empty: bool, )
engines/crates/furnace-io/src/runners/shared/writing.rs:49
↓ 6 callersFunctionensure_production_symbols
( indicator: &str, writes_applied: bool, symbols: &[String], )
engines/crates/furnace-io/src/runners/shared/writing.rs:36
↓ 6 callersFunctionensure_strategy_portfolio_active
(record: &StrategyPortfolioRecord)
engines/crates/rearview-core/src/api/mod.rs:6614
↓ 6 callersMethoderror_type
(&self)
engines/crates/rearview-core/src/error.rs:67
↓ 6 callersMethodexecute
(&mut self, sql: &str)
engines/crates/furnace-io/src/runners/tests/fixtures.rs:101
↓ 6 callersFunctionfake_s3_config
(bucket: str)
pipeline/scheduler/tests/unit/http/test_market_event_partitioning_and_schemas.py:48
↓ 6 callersMethodfinish
(self)
engines/crates/furnace/src/commands/common.rs:60
↓ 6 callersMethodfinish
( &self, input_rows: u64, output_rows: u64, symbols_count: u64, )
engines/crates/furnace-io/src/summary/common.rs:89
↓ 6 callersFunctionfixture_trade_date
(day: u8)
engines/crates/furnace-io/src/runners/tests/fixtures.rs:273
↓ 6 callersFunctionformatAccountCurrency
(value: number)
app/racingline/src/routes/strategy-detail-page.tsx:1843
↓ 6 callersFunctionformatOptionalRatio
(value: number | null | undefined)
app/racingline/src/routes/strategy-page.tsx:1487
↓ 6 callersFunctionformatOptionalSignedPercent
(value: number | null | undefined)
app/racingline/src/routes/strategy-detail-page.tsx:1890
↓ 6 callersFunctionformatWeightIndicator
( indicator: WeightIndicator, options: FormatIndicatorOptions = {} )
app/racingline/src/features/strategy/utils.ts:146
↓ 6 callersFunctioninputs
(values: &[Option<f64>])
engines/crates/furnace-core/src/indicators/moving_average.rs:515
↓ 6 callersFunctioninsert_typed_rows
( executor: &mut E, table: &str, rows: &[R], batch_size: usize, )
engines/crates/furnace-io/src/runners/shared/writing.rs:177
↓ 6 callersMethodinto_catalog
( self, dbt_marts_dir: impl AsRef<Path>, default_mart_database: &str, )
engines/crates/rearview-core/src/domain/catalog_policy.rs:118
↓ 6 callersFunctionis_common_flag
(flag: &str)
engines/crates/furnace/src/commands/common.rs:90
↓ 6 callersFunctionmetricFromPerformance
( label: string, performance: StrategyPortfolioPerformanceView | null, key: string, fallbackTone?: Met
app/racingline/src/routes/strategy-detail-page.tsx:1566
↓ 6 callersFunctionnext_flag_value
( args: &mut impl Iterator<Item = String>, flag: &str, )
engines/crates/furnace/src/commands/common.rs:103
↓ 6 callersFunctionnormalize_symbols
(symbols: &[String])
engines/crates/furnace-io/src/runners/shared/planning.rs:9
↓ 6 callersFunctionparse_preview_json_field
(raw: &str)
engines/crates/rearview-core/src/api/mod.rs:5686
↓ 6 callersFunctionplan_date_chunks
( start_date: NaiveDate, end_date: NaiveDate, threshold_days: u32, )
engines/crates/rearview-core/src/postgres/mod.rs:4115
↓ 6 callersFunctionportfolioRecord
()
app/racingline/src/routes/strategy-detail-page.test.tsx:594
↓ 6 callersFunctionpreviewSnapshot
(stale: boolean)
app/racingline/src/features/strategy/execution.test.ts:330
↓ 6 callersMethodquery
( self, query: str, *, settings: dict[str, object] | None = None, )
pipeline/scheduler/tests/unit/clickhouse/test_raw_sync.py:54
↓ 6 callersFunctionratioMetricFromPerformance
( label: string, performance: StrategyPortfolioPerformanceView | null, key: string )
app/racingline/src/routes/strategy-detail-page.tsx:1584
↓ 6 callersMethodread
(self)
pipeline/scheduler/src/scheduler/defs/http/protocols.py:75
↓ 6 callersFunctionreadFiniteNumber
(value: JsonValue | undefined)
app/racingline/src/features/strategy/config-display.ts:680
↓ 6 callersFunctionrebuild_output_schema
( executor: &mut E, output_table: &str, output_table_sql: String, )
engines/crates/furnace-io/src/runners/shared/writing.rs:24
↓ 6 callersFunctionreplace_partitions
( executor: &mut E, output_table: &str, staging_table: &str, years: &[u16], )
engines/crates/furnace-io/src/runners/shared/writing.rs:157
↓ 6 callersMethodrequest_json_object
(self, request: HttpRequest)
pipeline/scheduler/src/scheduler/defs/http/client.py:250
↓ 6 callersFunctionresetQuery
(query: { data: T | null error: unknown isError: boolean isLoading: boolean })
app/racingline/src/routes/strategy-detail-page.test.tsx:525
↓ 6 callersFunctionresolve_required_source_signal_date
( mut trade_dates: Vec<NaiveDate>, server_current_date: NaiveDate, server_current_time: NaiveTime,
engines/crates/rearview-core/src/api/mod.rs:6378
↓ 6 callersFunctionresolve_statement_period
( key: StatementPeriodKey, live_start_date: NaiveDate, latest_live_trade_date: NaiveDate, )
engines/crates/rearview-core/src/api/mod.rs:5884
↓ 6 callersFunctionrsi_window_state
(gain: f64, loss: f64)
engines/crates/furnace-io/src/runners/rsi/planning.rs:104
↓ 6 callersMethodset_chunk_finished
( &self, run_id: &str, chunk_no: i32, status: &str, error: Option<&Rea
engines/crates/rearview-core/src/postgres/mod.rs:2685
↓ 6 callersFunctionsetup_staging
( executor: &mut E, drop_sql: String, create_sql: String, )
engines/crates/furnace-io/src/runners/shared/writing.rs:134
↓ 6 callersFunctionshould_parallelize
( group_count: usize, input_row_count: usize, worker_threads: usize, )
engines/crates/furnace-io/src/runners/shared/parallel.rs:1
↓ 6 callersFunctionstaging_table_name
根据输出表和运行 ID 构造确定性的临时 staging 表名。 非字母数字字符会被规范化为 `_`，确保结果可以安全地作为 ClickHouse 标识符后缀。
engines/crates/furnace-io/src/schema/staging.rs:6
↓ 6 callersFunctionto_int8
将值转换为 int8，用于小整数列（标志位、状态码）。 None → 返回 None（缺失值） 转换失败时抛出 SchemaTypeError。 超出 int8 范围时抛出 SchemaTypeError。
pipeline/scheduler/src/scheduler/defs/common/types.py:102
↓ 6 callersMethodto_json
将摘要序列化为 JSON。
engines/crates/furnace-io/src/summary/ma.rs:54
↓ 6 callersMethodto_request
(&self)
engines/crates/furnace/src/commands/ma.rs:76
↓ 6 callersFunctionto_time32_ms
将 'HH:MM:SS' 转为 time 对象，用于 pa.time32('ms') 列。 JiuYan action_info.time 格式：'09:37:51' None → 返回 None（缺失值） 转换失败时抛出 SchemaTypeError。
pipeline/scheduler/src/scheduler/defs/common/types.py:198
↓ 6 callersMethodupdate_strategy_backtest_progress
( &self, strategy_backtest_run_id: &str, status: &str, progress: &Value, )
engines/crates/rearview-core/src/postgres/mod.rs:989
↓ 6 callersMethodupdate_strategy_portfolio_daily_progress
( &self, strategy_portfolio_daily_run_id: &str, status: &str, progress: &Value
engines/crates/rearview-core/src/postgres/mod.rs:1760
↓ 6 callersMethodvalidate
(self)
pipeline/scheduler/src/scheduler/defs/common/concurrency.py:22
↓ 6 callersMethodvalidate
(&self)
engines/crates/furnace/src/commands/ma.rs:72
↓ 6 callersFunctionvalidate_staging_or_error
( executor: &mut E, staging_table: &str, years: &[u16], )
engines/crates/furnace-io/src/runners/shared/writing.rs:142
↓ 6 callersMethodvalidate_table
(self, obj: object, *, allow_empty: bool = False)
pipeline/scheduler/src/scheduler/defs/io_managers/s3_io_manager.py:175
↓ 6 callersFunctionwrite_parquet_dataset
( table: pa.Table, base_dir: str, filesystem: PyArrowFileSystem, *, partition_key: str | N
pipeline/scheduler/src/scheduler/defs/storage/parquet.py:16
↓ 5 callersFunction_build_migration_client
( client: ClickHouseMigrationClient | None, )
pipeline/contract_tools/src/fleur_contracts/clickhouse_layer_migration.py:1173
↓ 5 callersFunction_positive_int
(value: int, name: str)
pipeline/scheduler/src/scheduler/defs/rearview/assets.py:429
↓ 5 callersFunction_registry_with
(*datasets: DatasetContract)
pipeline/contract_tools/tests/test_contract_registry.py:304
↓ 5 callersFunction_wait_for_daily_runs
( *, rearview_api: RearviewApiResource, daily_run_ids: list[str], poll_interval_seconds: int,
pipeline/scheduler/src/scheduler/defs/rearview/assets.py:203
↓ 5 callersMethodall_business_indicators_null
所有业务 RSI 字段是否均为空。
engines/crates/furnace-core/src/indicators/rsi.rs:246
↓ 5 callersFunctionassert_close
(left: f64, right: f64)
engines/crates/furnace-core/src/operators/ema.rs:128
↓ 5 callersFunctionassert_close
(left: f64, right: f64)
engines/crates/furnace-core/src/indicators/rsi.rs:534
↓ 5 callersFunctionassert_filter_number
( conditions: &[FilterExpr], index: usize, expected_left: &str, expected_op: O
engines/crates/rearview-core/src/examples.rs:456
↓ 5 callersFunctionbuild_furnace_defs
( *, binary_path: str = DEFAULT_FURNACE_BINARY_PATH, working_dir: str = ".", rayon_num_threads
pipeline/scheduler/src/scheduler/defs/furnace/definitions.py:9
↓ 5 callersFunctionbuild_request_params
( endpoint: EastmoneyEndpointConfig, code: str, start_date: date, end_date: date, *, p
pipeline/scheduler/src/scheduler/defs/sources/eastmoney/client.py:203
↓ 5 callersFunctionbuild_s3_filesystem
(config: S3Config)
pipeline/scheduler/src/scheduler/defs/storage/s3.py:45
↓ 5 callersFunctionbuild_year_ranges
( partition_keys: list[str], *, refresh_until_date: str | None = None, )
pipeline/scheduler/src/scheduler/defs/sources/chinabond/services.py:159
↓ 5 callersFunctioncalculate_boll_series
Calculate Bollinger Bands outputs for one ordered security series. # Errors Returns an error when parameters are invalid, prices are invalid, or tra
engines/crates/furnace-core/src/indicators/bollinger_bands.rs:279
↓ 5 callersFunctionclampScore
(score: number)
app/racingline/src/features/strategy/utils.ts:96
↓ 5 callersMethodclose
(self)
pipeline/scheduler/src/scheduler/defs/baostock/client.py:164
↓ 5 callersMethodcompile_backtest_signals
( &self, rule: &RuleVersionSpec, start_date: NaiveDate, end_date: NaiveDate,
engines/crates/rearview-core/src/planner/sql.rs:169
↓ 5 callersFunctionconfirmation_token
( timestamp: datetime | None, manifest: Mapping[str, object], )
pipeline/contract_tools/src/fleur_contracts/clickhouse_layer_migration.py:1003
↓ 5 callersFunctioncopy_selected_fields
( output_row: dict[str, object], source: Mapping[str, object], columns: Sequence[str], )
pipeline/scheduler/src/scheduler/defs/http/schemas.py:220
↓ 5 callersFunctionencode_request
( request_code: str, api_name: str, user_id: str, params: list[str], page: int = 1, pa
pipeline/scheduler/src/scheduler/defs/baostock/protocol.py:67
↓ 5 callersFunctionenv_int_or_default
(name: str, default: int)
pipeline/scheduler/src/scheduler/defs/config/env.py:34
↓ 5 callersFunctionenv_str_or_default
(name: str, default: str)
pipeline/scheduler/src/scheduler/defs/config/env.py:27
↓ 5 callersFunctionevent
( event_seq: &mut u32, trade_date: NaiveDate, security_code: Option<String>, event_type: Portf
engines/crates/rearview-core/src/portfolio/mod.rs:1096
↓ 5 callersMethodexit_rules
(self)
engines/crates/rearview-portfolio-worker/src/main.rs:1588
↓ 5 callersFunctionfake_s3_config
(bucket: str = "bucket")
pipeline/scheduler/tests/unit/storage/test_storage_and_services.py:28
↓ 5 callersFunctionfilter_active_security_ranges
( stock_basic: pa.Table, requested_start_date: date, requested_end_date: date, allowed_securit
pipeline/scheduler/src/scheduler/defs/market/securities.py:29
↓ 5 callersFunctionformatFeePercent
(value: number)
app/racingline/src/features/strategy/components/simulation-position-panel.tsx:1251
↓ 5 callersFunctionformatInteger
(value: number)
app/racingline/src/routes/strategy-detail-page.tsx:1847
↓ 5 callersFunctionformatOptionalSignedPercent
(value: number | null | undefined)
app/racingline/src/routes/strategy-page.tsx:1463
↓ 5 callersFunctiongetCatalogOptions
(catalogOptions?: IndicatorCatalog[])
app/racingline/src/features/strategy/utils.ts:411
← previousnext →201–300 of 3,759, ranked by callers