src.monitoring.assignment_monitor module#

Continuous monitoring for task assignment state changes.

This module monitors for task state reversions and handles them appropriately to prevent workers from being stuck with reverted tasks.

class src.monitoring.assignment_monitor.AssignmentMonitor[source]#

Bases: object

Monitors task assignments for state reversions and inconsistencies.

__init__(persistence, kanban_client, check_interval=30)[source]#

Initialize the assignment monitor.

Parameters:

  • persistence (AssignmentPersistence) – Assignment persistence layer

  • kanban_client (KanbanInterface) – Kanban board interface

  • check_interval (int) – How often to check for reversions (seconds)

async start()[source]#

Start monitoring for assignment reversions.

Return type:

None

async stop()[source]#

Stop the assignment monitor.

Return type:

None

async force_reconciliation()[source]#

Force a full reconciliation check.

Return type:

Dict[str, Any]

get_monitoring_stats()[source]#

Get current monitoring statistics.

Return type:

Dict[str, Any]

class src.monitoring.assignment_monitor.AssignmentHealthChecker[source]#

Bases: object

Performs periodic health checks on assignment system.

__init__(persistence, kanban_client, monitor)[source]#
Parameters:
async check_assignment_health()[source]#

Comprehensive health check of assignment system.

Returns:

Dictionary with health status and any issues found

Return type:

Dict[str, Any]