in handlers/aws/cloudwatch_logs_trigger.py [0:0]
def _handle_cloudwatch_logs_move(
sqs_client: BotoBaseClient,
sqs_destination_queue: str,
cloudwatch_logs_event: dict[str, Any],
input_id: str,
config_yaml: str,
continuing_queue: bool = True,
current_log_event: int = 0,
last_ending_offset: Optional[int] = None,
last_event_expanded_offset: Optional[int] = None,