Source code for parsl_ephemeral_provider.exceptions

"""
Custom exceptions for the EphemeralProvider.

SPDX-License-Identifier: Apache-2.0
SPDX-FileCopyrightText: 2025-2026 Scott Friedman and Project Contributors
"""

from botocore.exceptions import NoCredentialsError as _BotoNoCredentialsError




class CredentialResolutionError(_BotoNoCredentialsError):
    """No usable AWS credentials could be resolved, with a reason.

    botocore's ``NoCredentialsError`` derives from ``BotoCoreError``, whose
    ``__init__`` accepts **keyword arguments only** and formats them into a
    fixed class-level ``fmt`` — so ``NoCredentialsError("why")`` raises
    ``TypeError: BotoCoreError.__init__() takes 1 positional argument but 2
    were given`` and the reason never reaches the caller. Every raise site in
    ``security/credential_manager.py`` did exactly that, turning each of the
    seven distinct credential failures into the same opaque ``TypeError``.

    Subclassing keeps ``except NoCredentialsError`` handlers working —
    ``compute/{ec2,ecs,lambda_func,spot_fleet}.py`` and
    ``error_handling.py:269`` all catch the botocore class and must continue to
    — while allowing the message through.
    """

    fmt = "{message}"

    def __init__(self, message: str) -> None:
        super().__init__(message=message)





class EphemeralAWSError(Exception):
    """Base class for all EphemeralProvider exceptions."""

    pass





class ProviderError(EphemeralAWSError):
    """General provider error."""

    pass





class ProviderConfigurationError(ProviderError):
    """Error in provider configuration."""

    pass





class AWSConnectionError(ProviderError):
    """Error connecting to AWS services."""

    pass





class AWSAuthenticationError(AWSConnectionError):
    """AWS authentication failure."""

    pass





class ResourceCreationError(ProviderError):
    """Error creating AWS resources."""

    pass





class ResourceDeletionError(ProviderError):
    """Error deleting AWS resources."""

    pass





class ResourceCleanupError(ResourceDeletionError):
    """Error cleaning up AWS resources."""

    pass





class ResourceNotFoundError(ProviderError):
    """Requested AWS resource not found."""

    pass





class ConfigurationError(ProviderConfigurationError):
    """Error in provider configuration."""

    pass





class JobSubmissionError(ProviderError):
    """Error submitting job for execution."""

    pass





class StateStoreError(ProviderError):
    """Error in state store operations."""

    pass





class StateError(StateStoreError):
    """General state management error - alias for compatibility."""

    pass





class StateSerializationError(StateStoreError):
    """Error serializing state data."""

    pass





class StateDeserializationError(StateStoreError):
    """Error deserializing state data."""

    pass





class JobExecutionError(ProviderError):
    """Error executing a job."""

    pass





class JobCancellationError(ProviderError):
    """Error cancelling a job."""

    pass





class NetworkCreationError(ResourceCreationError):
    """Error creating network resources."""

    pass





class SecurityGroupError(ResourceCreationError):
    """Error managing security groups."""

    pass





class EC2InstanceError(ResourceCreationError):
    """Error managing EC2 instances."""

    pass





class LambdaFunctionError(ResourceCreationError):
    """Error managing Lambda functions."""

    pass





class ECSTaskError(ResourceCreationError):
    """Error managing ECS tasks."""

    pass





class BastionHostError(ResourceCreationError):
    """Error managing bastion hosts."""

    pass





class SpotInstanceError(EC2InstanceError):
    """Error managing spot instances."""

    pass





class SpotFleetError(EC2InstanceError):
    """Error managing EC2 Spot Fleet."""

    pass





class SpotFleetRequestError(SpotFleetError):
    """Error creating or managing Spot Fleet requests."""

    pass





class SpotFleetThrottlingError(SpotFleetError):
    """AWS API throttling for Spot Fleet operations."""

    def __init__(
        self,
        message="AWS Spot Fleet API request was throttled",
        operation=None,
        retry_after=None,
    ):
        self.operation = operation
        self.retry_after = retry_after
        super().__init__(message)





class OperatingModeError(ProviderError):
    """Error in operating mode functionality."""

    pass





class CloudFormationError(ResourceCreationError):
    """Error in CloudFormation stack operations."""

    pass





class TaskTimeoutError(JobExecutionError):
    """Task execution timeout."""

    pass





class SpotInterruptionError(SpotInstanceError):
    """Error related to spot instance interruption."""

    pass





class InvalidStateError(ProviderError):
    """Provider is in an invalid state for the requested operation."""

    pass





class TaggingError(ProviderError):
    """Error tagging AWS resources."""

    pass





class CleanupError(ProviderError):
    """Error cleaning up resources."""

    pass





class AMINotFoundError(ResourceCreationError):
    """Specified AMI not found."""

    pass