fraudtwin.iter_scale_records#

fraudtwin.iter_scale_records(config, entities, *, simulation_run_id, stage_timings=None)[source][source]#

Stream canonical entities, profiles, payments, events, and ledger rows.

This iterator is the scale writer’s producer-facing API. It deliberately keeps only generator state and account balances; records are never accumulated into a BehaviorDataset. Advanced fraud/graph stages still use the compatibility generator until their own streaming implementations are available.

Return type:

Iterator[dict[str, object]]

Parameters:

  • config (SimulationRunConfig)

  • entities (EntityDataset)

  • simulation_run_id (str)

  • stage_timings (dict[str, dict[str, float]] | None)