22709357475

Committed 05 Mar 2026 08:35AM UTC coverage: 59.732% (-27.2%) from 86.974%

Build # 22709357475

Build Type

Pull #13880

github

Committed by

web-flow

Commit Message

Merge 28fcab93c into 710618057

Pull Request Pull Request #13880: Firehose: Replace TaggingService

Coverage Stats

12 of 12 new or added lines in 2 files covered. (100.0%)

20464 existing lines in 510 files now uncovered.

45290 of 75822 relevant lines covered (59.73%)

0.6 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

73.08

/localstack-core/localstack/services/lambda_/event_source_mapping/senders/sender.py

from abc import abstractmethod

from botocore.client import BaseClient

from localstack.services.lambda_.event_source_mapping.pipe_utils import get_internal_client


class SenderError(Exception):
    def __init__(self, message=None, error=None) -> None:
        self.message = message or "Error during sending events"
        self.error = error


class PartialFailureSenderError(SenderError):
    def __init__(self, message=None, error=None, partial_failure_payload=None) -> None:
        self.message = message or "Target invocation failed partially."
        self.error = error
        # Following the partial failure payload structure:
        # https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-batching-concurrency.html
        self.partial_failure_payload = partial_failure_payload


class Sender:
    target_arn: str
    target_parameters: dict
    target_client: BaseClient

    def __init__(
        self,
        target_arn: str,
        target_parameters: dict | None = None,
        target_client: BaseClient | None = None,
    ) -> None:
        self.target_arn = target_arn
        self.target_parameters = target_parameters or {}
        self.target_client = target_client or get_internal_client(target_arn)

    # TODO: Can an event also be of type `bytes`?
    @abstractmethod
    def send_events(self, events: list[dict | str]) -> dict | None:
        """Send the given `events` to the target.
        Returns an optional payload with a list of "batchItemFailures" if only part of the batch succeeds.
        """
        pass

    @abstractmethod
    def event_target(self) -> str:
        """Return the event target metadata (e.g., aws:sqs)
        Format analogous to event_source of pollers"""
        pass

1	from abc import abstractmethod	1✔
2
3	from botocore.client import BaseClient	1✔
4
5	from localstack.services.lambda_.event_source_mapping.pipe_utils import get_internal_client	1✔
6
7
8	class SenderError(Exception):	1✔
9	def __init__(self, message=None, error=None) -> None:	1✔
UNCOV 10	self.message = message or "Error during sending events"	×
UNCOV 11	self.error = error	×
12
13
14	class PartialFailureSenderError(SenderError):	1✔
15	def __init__(self, message=None, error=None, partial_failure_payload=None) -> None:	1✔
UNCOV 16	self.message = message or "Target invocation failed partially."	×
UNCOV 17	self.error = error	×
18	# Following the partial failure payload structure:
19	# https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-batching-concurrency.html
UNCOV 20	self.partial_failure_payload = partial_failure_payload	×
21
22
23	class Sender:	1✔
24	target_arn: str	1✔
25	target_parameters: dict	1✔
26	target_client: BaseClient	1✔
27
28	def __init__(	1✔
29	self,
30	target_arn: str,
31	target_parameters: dict \| None = None,
32	target_client: BaseClient \| None = None,
33	) -> None:
34	self.target_arn = target_arn	1✔
35	self.target_parameters = target_parameters or {}	1✔
36	self.target_client = target_client or get_internal_client(target_arn)	1✔
37
38	# TODO: Can an event also be of type `bytes`?
39	@abstractmethod	1✔
40	def send_events(self, events: list[dict \| str]) -> dict \| None:	1✔
41	"""Send the given `events` to the target.
42	Returns an optional payload with a list of "batchItemFailures" if only part of the batch succeeds.
43	"""
44	pass	×
45
46	@abstractmethod	1✔
47	def event_target(self) -> str:	1✔
48	"""Return the event target metadata (e.g., aws:sqs)
49	Format analogous to event_source of pollers"""
50	pass	×

localstack / localstack / 22709357475

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous