Skip to content

Run

interfaces.fetch_request.cli.run

Summary

Pipeline runner subcommand — drives _extract → _enrich → _process_expenses with a --till guard that stops the run after a given stage.

Classes

Functions

cmd_run async

cmd_run(args)

Run the pipeline for a fetch request using parsed CLI arguments.

Parameters:

Name Type Description Default
args

Parsed argparse namespace with id, till, force, and resume fields.

required

run_pipeline async

1
2
3
4
5
6
7
8
run_pipeline(
    fr_id: str,
    *,
    till: str = "expense",
    force: bool = False,
    resume: bool = False,
    splitter=None
)

Run the extraction pipeline for a fetch request.

Fetches the source content, extracts raw expenses, enriches them, and saves them as expenses, stopping between stages when till asks for it.

Parameters:

Name Type Description Default
fr_id str

Fetch request id.

required
till str

Stop stage: raw, enriched, or expense. Defaults to expense.

'expense'
force bool

Reset to pending and clear extraction data before running. Defaults to False.

False
resume bool

Load previously resolved choices before running. Defaults to False.

False
splitter

Optional custom splitter injected into the extractor.

None