fraudtwin.ScalePlan#

class fraudtwin.ScalePlan(**data)[source][source]#

Bases: BaseModel

Resolved, immutable execution parameters for one scale run.

Parameters:

  • profile (Literal['dev', 'small', 'medium', 'large', 'xlarge', 'billion'])

  • target_logical_events (int)

  • shard_count (int)

  • chunk_size (int)

  • worker_count (int)

  • output_batch_size (int)

  • checkpoint_frequency_chunks (int)

  • partition_mapping (Literal['stable_hash_v1'])

  • seed (int)

  • run_id (str)

  • configuration_hash (str)

  • target_payments (int)

  • seed_tree_version (str)

  • features (tuple[Literal['entities', 'behavior', 'payments', 'lifecycle', 'ledger', 'fraud', 'labels', 'graph', 'pit', 'backtest'], ...])

  • storage_backend (Literal['local', 'fsspec'])

  • storage_uri (str | None)

  • state_backend (Literal['duckdb'])

  • manifest_version (str)

model_config: ClassVar[ConfigDict] = {'extra': 'forbid', 'frozen': True}#

Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].