src.core package#
Submodules#
- src.core.adaptive_dependencies module
DependencySignalRelationshipPatternDependencyFeedbackUserRelationshipWorkflowPatternDependencyInterfaceAdaptiveDependencyInfererAdaptiveDependencyInferer.__init__()AdaptiveDependencyInferer.patternsAdaptiveDependencyInferer.feedback_historyAdaptiveDependencyInferer.user_relationshipsAdaptiveDependencyInferer.workflow_patternsAdaptiveDependencyInferer.infer_dependency()AdaptiveDependencyInferer.record_feedback()AdaptiveDependencyInferer.get_confidence_explanation()AdaptiveDependencyInferer.suggest_dependencies()AdaptiveDependencyInferer.learn_from_kanban_board()AdaptiveDependencyInferer.get_inference_mode()AdaptiveDependencyInferer.should_require_confirmation()
- src.core.ai_powered_task_assignment module
- src.core.assignment_lease module
LeaseStatusAssignmentLeaseAssignmentLease.task_idAssignmentLease.agent_idAssignmentLease.assigned_atAssignmentLease.lease_expiresAssignmentLease.last_renewedAssignmentLease.renewal_countAssignmentLease.estimated_hoursAssignmentLease.progress_percentageAssignmentLease.last_progress_messageAssignmentLease.grace_period_secondsAssignmentLease.update_timestampsAssignmentLease.merge_conflict_extensionsAssignmentLease.median_update_intervalAssignmentLease.time_remainingAssignmentLease.is_expiredAssignmentLease.is_expiring_soonAssignmentLease.statusAssignmentLease.calculate_renewal_duration()AssignmentLease.__init__()
AssignmentLeaseManagerAssignmentLeaseManager.__init__()AssignmentLeaseManager.active_leasesAssignmentLeaseManager.recoveries_skipped_terminal_statusAssignmentLeaseManager.on_recovery_callbackAssignmentLeaseManager.lease_historyAssignmentLeaseManager.lease_lockAssignmentLeaseManager.update_task_list()AssignmentLeaseManager.create_lease()AssignmentLeaseManager.renew_lease()AssignmentLeaseManager.touch_lease()AssignmentLeaseManager.check_expired_leases()AssignmentLeaseManager.recover_expired_lease()AssignmentLeaseManager.get_expiring_leases()AssignmentLeaseManager.load_active_leases()AssignmentLeaseManager.get_lease_statistics()AssignmentLeaseManager.calculate_adaptive_timeout()AssignmentLeaseManager.should_recover_expired_lease()
LeaseMonitor
- src.core.assignment_persistence module
AssignmentPersistenceAssignmentPersistence.__init__()AssignmentPersistence.lockAssignmentPersistence.save_assignment()AssignmentPersistence.remove_assignment()AssignmentPersistence.get_assignment()AssignmentPersistence.get_all_assigned_task_ids()AssignmentPersistence.load_assignments()AssignmentPersistence.is_task_assigned()AssignmentPersistence.get_worker_for_task()AssignmentPersistence.cleanup()
- src.core.assignment_reconciliation module
- src.core.board_health_analyzer module
- src.core.code_analyzer module
- src.core.context module
TaskContextDependentTaskDecisionContextContext.__init__()Context.implementationsContext.dependenciesContext.decisionsContext.patternsContext.add_implementation()Context.add_dependency()Context.log_decision()Context.get_context()Context.analyze_dependencies()Context.infer_needed_interface()Context.suggest_task_order()Context.get_decisions_for_task()Context.get_implementation_summary()Context.clear_old_data()
- src.core.error_framework module
ErrorSeverityErrorCategoryErrorContextErrorContext.operationErrorContext.operation_idErrorContext.agent_idErrorContext.task_idErrorContext.agent_stateErrorContext.timestampErrorContext.correlation_idErrorContext.system_stateErrorContext.integration_nameErrorContext.integration_stateErrorContext.user_contextErrorContext.custom_contextErrorContext.__init__()
RemediationSuggestionMarcusBaseErrorTransientErrorNetworkTimeoutErrorServiceUnavailableErrorRateLimitErrorTemporaryResourceErrorConfigurationErrorMissingCredentialsErrorInvalidConfigurationErrorMissingDependencyErrorEnvironmentErrorBusinessLogicErrorTaskAssignmentErrorWorkflowViolationErrorValidationErrorStateConflictErrorTaskValidationErrorProjectRootNotFoundErrorIntegrationErrorKanbanIntegrationErrorAIProviderErrorAuthenticationErrorExternalServiceErrorSecurityErrorAuthorizationErrorWorkspaceSecurityErrorPermissionErrorSystemErrorResourceExhaustionErrorCorruptedStateErrorDatabaseErrorCriticalDependencyErrorerror_context()ErrorResponseFormatterMarcusError
- src.core.error_monitoring module
AlertSeverityErrorMetricsErrorMetrics.total_errorsErrorMetrics.errors_by_typeErrorMetrics.errors_by_severityErrorMetrics.errors_by_categoryErrorMetrics.errors_by_agentErrorMetrics.errors_by_operationErrorMetrics.retryable_errorsErrorMetrics.critical_errorsErrorMetrics.error_rate_per_minuteErrorMetrics.last_updatedErrorMetrics.__init__()
ErrorPatternCorrelationGroupErrorMonitorErrorMonitor.__init__()ErrorMonitor.error_historyErrorMonitor.error_indexErrorMonitor.metrics_historyErrorMonitor.detected_patternsErrorMonitor.correlation_groupsErrorMonitor.active_correlationsErrorMonitor.alert_callbacksErrorMonitor.record_error()ErrorMonitor.add_alert_callback()ErrorMonitor.get_current_metrics()ErrorMonitor.get_metrics_history()ErrorMonitor.get_detected_patterns()ErrorMonitor.get_correlation_groups()ErrorMonitor.get_error_details()ErrorMonitor.search_errors()ErrorMonitor.generate_health_report()ErrorMonitor.start_monitoring()ErrorMonitor.stop_monitoring()
setup_error_monitoring()record_error_for_monitoring()get_error_health_status()
- src.core.error_responses module
ResponseFormatErrorResponseConfigErrorResponseConfig.include_debug_infoErrorResponseConfig.include_stack_traceErrorResponseConfig.include_system_contextErrorResponseConfig.include_remediationErrorResponseConfig.max_message_lengthErrorResponseConfig.sanitize_sensitive_dataErrorResponseConfig.custom_fieldsErrorResponseConfig.__init__()
ErrorResponseFormatterBatchErrorResponseFormattercreate_success_response()create_error_response()handle_mcp_tool_error()
- src.core.error_strategies module
- Status
CircuitBreakerStateRetryPolicyRetryConfigCircuitBreakerConfigCircuitBreakerStatusCircuitBreakerRetryHandlerFallbackHandlerErrorAggregatorwith_retry()with_circuit_breaker()with_fallback()ErrorStrategyRegistryErrorStrategyRegistry.__init__()ErrorStrategyRegistry.circuit_breakersErrorStrategyRegistry.fallback_handlersErrorStrategyRegistry.retry_configsErrorStrategyRegistry.get_circuit_breaker()ErrorStrategyRegistry.get_fallback_handler()ErrorStrategyRegistry.register_retry_config()ErrorStrategyRegistry.get_retry_config()ErrorStrategyRegistry.get_health_status()
- src.core.event_loop_utils module
- src.core.events module
EventEventsEventTypesEventTypes.TASK_REQUESTEDEventTypes.TASK_ASSIGNEDEventTypes.TASK_STARTEDEventTypes.TASK_PROGRESSEventTypes.TASK_COMPLETEDEventTypes.TASK_BLOCKEDEventTypes.BLOCKER_RESOLVEDEventTypes.AGENT_REGISTEREDEventTypes.AGENT_STATUS_CHANGEDEventTypes.AGENT_SKILL_UPDATEDEventTypes.PROJECT_CREATEDEventTypes.PROJECT_UPDATEDEventTypes.PROJECT_COMPLETEDEventTypes.SYSTEM_STARTUPEventTypes.SYSTEM_SHUTDOWNEventTypes.KANBAN_CONNECTEDEventTypes.KANBAN_ERROREventTypes.CONTEXT_UPDATEDEventTypes.DEPENDENCY_DETECTEDEventTypes.IMPLEMENTATION_FOUNDEventTypes.DECISION_LOGGEDEventTypes.PATTERN_DETECTEDEventTypes.PLANNING_INTENT_FIDELITYEventTypes.PREDICTION_MADEEventTypes.AGENT_LEARNEDEventTypes.ERROREventTypes.WARNING
- src.core.memory module
TaskOutcomeAgentProfileAgentProfile.agent_idAgentProfile.total_tasksAgentProfile.successful_tasksAgentProfile.failed_tasksAgentProfile.blocked_tasksAgentProfile.skill_success_ratesAgentProfile.average_estimation_accuracyAgentProfile.common_blockersAgentProfile.peak_performance_hoursAgentProfile.success_rateAgentProfile.blockage_rateAgentProfile.__init__()
TaskPatternMemoryMemory.__init__()Memory.workingMemory.episodicMemory.semanticMemory.proceduralMemory.record_task_start()Memory.record_task_completion()Memory.predict_task_outcome()Memory.predict_completion_time()Memory.get_median_duration_by_type()Memory.predict_blockage_probability()Memory.predict_cascade_effects()Memory.calculate_agent_performance_trajectory()Memory.find_similar_outcomes()Memory.get_global_median_duration()Memory.get_working_memory_summary()Memory.update_project_tasks()Memory.get_memory_stats()
- src.core.memory_advanced module
- src.core.models module
TaskStatusRiskLevelPriorityRecoveryInfoRecoveryInfo.recovered_atRecoveryInfo.recovered_from_agentRecoveryInfo.previous_progressRecoveryInfo.time_spent_minutesRecoveryInfo.recovery_reasonRecoveryInfo.instructionsRecoveryInfo.previous_agent_branchRecoveryInfo.recovery_expires_atRecoveryInfo.to_dict()RecoveryInfo.from_dict()RecoveryInfo.__init__()
TaskTask.idTask.nameTask.descriptionTask.statusTask.priorityTask.assigned_toTask.created_atTask.updated_atTask.due_dateTask.estimated_hoursTask.actual_hoursTask.dependenciesTask.dependency_typesTask.labelsTask.project_idTask.project_nameTask.source_typeTask.source_contextTask.completion_criteriaTask.acceptance_criteriaTask.validation_specTask.is_subtaskTask.parent_task_idTask.subtask_indexTask.providesTask.requiresTask.responsibilityTask.output_pathsTask.recovery_infoTask.__init__()
ProjectStateProjectState.board_idProjectState.project_nameProjectState.total_tasksProjectState.completed_tasksProjectState.in_progress_tasksProjectState.blocked_tasksProjectState.progress_percentProjectState.overdue_tasksProjectState.team_velocityProjectState.risk_levelProjectState.last_updatedProjectState.__init__()
WorkerStatusTaskAssignmentTaskAssignment.task_idTaskAssignment.task_nameTaskAssignment.descriptionTaskAssignment.instructionsTaskAssignment.estimated_hoursTaskAssignment.priorityTaskAssignment.dependenciesTaskAssignment.assigned_toTaskAssignment.assigned_atTaskAssignment.due_dateTaskAssignment.workspace_pathTaskAssignment.forbidden_pathsTaskAssignment.__init__()
BlockerReportProjectRisk
- src.core.persistence module
- src.core.phase_dependency_enforcer module
- src.core.project_context_manager module
ProjectContextProjectContextManagerProjectContextManager.MAX_CACHED_PROJECTSProjectContextManager.IDLE_TIMEOUT_MINUTESProjectContextManager.__init__()ProjectContextManager.lockProjectContextManager.set_global_context()ProjectContextManager.initialize()ProjectContextManager.shutdown()ProjectContextManager.switch_project()ProjectContextManager.get_kanban_client()ProjectContextManager.get_active_context()ProjectContextManager.get_active_events()ProjectContextManager.get_active_project_state()ProjectContextManager.get_active_assignment_persistence()
- src.core.project_registry module
ProjectConfigProjectRegistryProjectRegistry.COLLECTIONProjectRegistry.ACTIVE_PROJECT_KEYProjectRegistry.__init__()ProjectRegistry.initialize()ProjectRegistry.add_project()ProjectRegistry.get_project()ProjectRegistry.list_projects()ProjectRegistry.update_project()ProjectRegistry.delete_project()ProjectRegistry.set_active_project()ProjectRegistry.get_active_project()ProjectRegistry.create_from_legacy_config()
- src.core.resilience module
- src.core.service_registry module
- src.core.task_recovery module
- src.core.workspace module
WorkspaceSecurityErrorWorkspaceConfigProjectWorkspacesWorkspaceManagerWorkspaceManager.marcus_rootWorkspaceManager.forbidden_pathsWorkspaceManager.agent_workspacesWorkspaceManager.project_configWorkspaceManager.__init__()WorkspaceManager.marcus_rootWorkspaceManager.forbidden_pathsWorkspaceManager.agent_workspacesWorkspaceManager.project_configWorkspaceManager.load_config()WorkspaceManager.assign_agent_workspace()WorkspaceManager.get_agent_workspace()WorkspaceManager.validate_path()WorkspaceManager.is_path_allowed()WorkspaceManager.add_forbidden_path()WorkspaceManager.get_forbidden_paths()WorkspaceManager.get_task_assignment_data()WorkspaceManager.log_security_violation()