worker_reports.py File Reference

Go to the source code of this file.

Classes
class	oc_connect.worker_reports.WorkerReportError
class	oc_connect.worker_reports.WorkerReportRelayError
class	oc_connect.worker_reports.WorkerReportEvent
class	oc_connect.worker_reports.WorkerReportStore
class	oc_connect.worker_reports.RelayOutcome
class	oc_connect.worker_reports.WorkerReportRelay

Namespaces
namespace	oc_connect
namespace	oc_connect.worker_reports

Functions
str	oc_connect.worker_reports.chunk_prefix (int index, int total)
tuple[str,...]	oc_connect.worker_reports.chunk_summary (str summary, *, int limit=TELEGRAM_MESSAGE_LIMIT)
str	oc_connect.worker_reports.render_chunk (str piece, int index, int total)
str	oc_connect.worker_reports.render_event (WorkerReportEvent event)
None	oc_connect.worker_reports._atomic_write (Path path, str payload)

Variables
str	oc_connect.worker_reports.WORKER_REPORT_LANE = "worker-reports"
str	oc_connect.worker_reports.WORKER_REPORT_SOURCE = "worker"
str	oc_connect.worker_reports.WORKER_REPORT_SCHEMA_VERSION = "1.0"
int	oc_connect.worker_reports.TELEGRAM_MESSAGE_LIMIT = 4096
int	oc_connect.worker_reports.MIN_CHUNK_LIMIT = 32
	oc_connect.worker_reports.WorkerReportStatus = Literal["awaiting_gate", "blocked"]
str	oc_connect.worker_reports.WORKER_REPORT_BEGIN = "<<<BEGIN WORKER REPORT {event_id}>>>"
str	oc_connect.worker_reports.WORKER_REPORT_END = "<<<END WORKER REPORT {event_id}>>>"
str	oc_connect.worker_reports.NEUTRALISED_MARKER = "<< <"