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
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
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
|