fraudtwin.iter_scale_run#

fraudtwin.iter_scale_run(config=None, *, entities=None, run_dir=None, simulation_run_id=None)[source][source]#

Yield scale records from a producer or an existing partitioned run.

Supplying run_dir reads one Parquet chunk at a time. Supplying entities exposes the canonical producer stream for integrations that already own an entity source. Exactly one source must be provided.

Return type:

Iterator[dict[str, object]]

Parameters:

  • config (SimulationRunConfig | None)

  • entities (EntityDataset | None)

  • run_dir (str | Path | None)

  • simulation_run_id (str | None)