{% extends "system_base.html" %} {% block title %}pipeline — defossil{% endblock %} {% block system_content %}

Pipeline

Every sweep runs collect → classify → review batches of {{ batch_size }} → report per {{ window }} corrections.

state
{% if pipeline_enabled() %}on — sweeps every {{ sweep_interval | dur }} {% else %}off — paused; nothing runs, not even collection{% endif %}
last sweep
{% if pipeline %} {{ pipeline.swept_at | ago }} — {% if pipeline.error %} failed {{ pipeline.error }} {% else %} {{ pipeline.new_messages }} new message{{ 's' if pipeline.new_messages != 1 }}, {{ pipeline.reviewed }} reviewed, {{ pipeline.corrections }} correction{{ 's' if pipeline.corrections != 1 }}, {{ pipeline.reports }} report{{ 's' if pipeline.reports != 1 }} {% endif %} {% elif pipeline_enabled() %} first sweep still running {% else %} no sweep yet {% endif %}
{% if pipeline_enabled() and pipeline %}
next sweep
in ~{{ next_sweep_in | dur }}
{% endif %}
next review
{{ pending }} / {{ batch_size }} messages pending — a review runs on a full batch
next report
{{ unreported }} / {{ window }} corrections
{% endblock %}