Skip to content

Exceptions

execution.models.exceptions

__all__ = ['OwlWatchExecutionException', 'ConfigurationException', 'MissingConfigurationError', 'InvalidConfigurationError', 'ConfigurationValidationError', 'SchemaException', 'SchemaValidationError', 'InvalidSchemaError', 'DataProcessingException', 'DataProcessingError', 'DataQualityError', 'JobExecutionException', 'JobExecutionError', 'JobTimeoutError', 'AWSException', 'S3Error', 'AthenaError', 'GlueError', 'AIProcessingException', 'BedrockError', 'SentimentAnalysisError', 'create_error_context', 'handle_exception_with_context'] module-attribute

OwlWatchExecutionException

message = message instance-attribute

context = context or {} instance-attribute

timestamp = timestamp or datetime.now(UTC) instance-attribute

__init__(message: str, context: Optional[Dict[str, Any]] = None, timestamp: Optional[datetime] = None)

to_dict() -> Dict[str, Any]

ConfigurationException

MissingConfigurationError

parameters = parameters instance-attribute

__init__(parameters: List[str], message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

InvalidConfigurationError

parameter = parameter instance-attribute

value = value instance-attribute

expected = expected instance-attribute

__init__(parameter: str, value: Any, expected: str, message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

ConfigurationValidationError

validation_errors = validation_errors instance-attribute

__init__(validation_errors: List[str], message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

SchemaException

SchemaValidationError

schema_name = schema_name instance-attribute

validation_errors = validation_errors instance-attribute

__init__(schema_name: str, validation_errors: List[str], message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

InvalidSchemaError

schema_name = schema_name instance-attribute

reason = reason instance-attribute

__init__(schema_name: str, reason: str, message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

DataProcessingException

DataProcessingError

operation = operation instance-attribute

reason = reason instance-attribute

record_count = record_count instance-attribute

__init__(operation: str, reason: str, record_count: Optional[int] = None, message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

DataQualityError

quality_check = quality_check instance-attribute

failed_records = failed_records instance-attribute

total_records = total_records instance-attribute

threshold = threshold instance-attribute

failure_rate = failed_records / total_records if total_records > 0 else 0.0 instance-attribute

__init__(quality_check: str, failed_records: int, total_records: int, threshold: Optional[float] = None, message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

JobExecutionException

TypeMismatchError

field_name = field_name instance-attribute

expected_type = expected_type instance-attribute

actual_type = actual_type instance-attribute

record_id = record_id instance-attribute

__init__(field_name: str, expected_type: str, actual_type: str, record_id: Optional[str] = None, message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

MissingFieldError

missing_fields = missing_fields instance-attribute

record_id = record_id instance-attribute

__init__(missing_fields: List[str], record_id: Optional[str] = None, message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

JobExecutionError

job_name = job_name instance-attribute

stage = stage instance-attribute

reason = reason instance-attribute

__init__(job_name: str, stage: str, reason: str, message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

JobTimeoutError

job_name = job_name instance-attribute

timeout_seconds = timeout_seconds instance-attribute

elapsed_seconds = elapsed_seconds instance-attribute

__init__(job_name: str, timeout_seconds: int, elapsed_seconds: int, message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

AWSException

S3Error

operation = operation instance-attribute

bucket = bucket instance-attribute

key = key instance-attribute

reason = reason instance-attribute

__init__(operation: str, bucket: str, key: Optional[str] = None, reason: str = 'Unknown error', message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

AthenaError

operation = operation instance-attribute

query_id = query_id instance-attribute

reason = reason instance-attribute

__init__(operation: str, query_id: Optional[str] = None, reason: str = 'Unknown error', message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

GlueError

operation = operation instance-attribute

job_name = job_name instance-attribute

reason = reason instance-attribute

__init__(operation: str, job_name: Optional[str] = None, reason: str = 'Unknown error', message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

AIProcessingException

BedrockError

model_id = model_id instance-attribute

operation = operation instance-attribute

reason = reason instance-attribute

__init__(model_id: str, operation: str, reason: str = 'Unknown error', message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

SentimentAnalysisError

text_sample = text_sample[:100] + '...' if len(text_sample) > 100 else text_sample instance-attribute

reason = reason instance-attribute

__init__(text_sample: str, reason: str = 'Unknown error', message: Optional[str] = None, context: Optional[Dict[str, Any]] = None)

create_error_context(job_name: Optional[str] = None, stage: Optional[str] = None, record_id: Optional[str] = None, **additional_context) -> Dict[str, Any]

handle_exception_with_context(exception: Exception, job_name: Optional[str] = None, stage: Optional[str] = None, record_id: Optional[str] = None, **additional_context) -> OwlWatchExecutionException