LICENSE
README.md
pyproject.toml
src/capo_pipes/__init__.py
src/capo_pipes/_async.py
src/capo_pipes/_body.py
src/capo_pipes/_iter.py
src/capo_pipes/_pagination.py
src/capo_pipes/py.typed
src/capo_pipes.egg-info/PKG-INFO
src/capo_pipes.egg-info/SOURCES.txt
src/capo_pipes.egg-info/dependency_links.txt
src/capo_pipes.egg-info/requires.txt
src/capo_pipes.egg-info/top_level.txt
src/capo_pipes/_auth/_identity.py
src/capo_pipes/_auth/_providers.py
src/capo_pipes/_auth/_signers.py
src/capo_pipes/_auth/_sigv4.py
src/capo_pipes/_auth/_zapros_handler.py
src/capo_pipes/_operations/pipes/create_pipe.py
src/capo_pipes/_operations/pipes/delete_pipe.py
src/capo_pipes/_operations/pipes/describe_pipe.py
src/capo_pipes/_operations/pipes/list_pipes.py
src/capo_pipes/_operations/pipes/list_tags_for_resource.py
src/capo_pipes/_operations/pipes/start_pipe.py
src/capo_pipes/_operations/pipes/stop_pipe.py
src/capo_pipes/_operations/pipes/tag_resource.py
src/capo_pipes/_operations/pipes/untag_resource.py
src/capo_pipes/_operations/pipes/update_pipe.py
src/capo_pipes/_protocol/__init__.py
src/capo_pipes/_protocol/errors.py
src/capo_pipes/_protocol/eventstream.py
src/capo_pipes/_protocol/serialize.py
src/capo_pipes/_protocol/xml.py
src/capo_pipes/_resources/pipes/pipe_resource.py
src/capo_pipes/_rule_engine/__init__.py
src/capo_pipes/_rule_engine/_aws_partition.py
src/capo_pipes/_rule_engine/_endpoint_rule_set.py
src/capo_pipes/_rule_engine/_endpoint_runtime.py
src/capo_pipes/_services/_aws_config.py
src/capo_pipes/_services/_pipeline.py
src/capo_pipes/_services/async_pipes.py
src/capo_pipes/_services/pipes.py
src/capo_pipes/errors/__init__.py
src/capo_pipes/errors/_base.py
src/capo_pipes/errors/conflict_exception.py
src/capo_pipes/errors/internal_exception.py
src/capo_pipes/errors/not_found_exception.py
src/capo_pipes/errors/service_quota_exceeded_exception.py
src/capo_pipes/errors/throttling_exception.py
src/capo_pipes/errors/validation_exception.py
src/capo_pipes/types/arn.py
src/capo_pipes/types/arn_or_json_path.py
src/capo_pipes/types/arn_or_url.py
src/capo_pipes/types/assign_public_ip.py
src/capo_pipes/types/aws_vpc_configuration.py
src/capo_pipes/types/batch_array_properties.py
src/capo_pipes/types/batch_array_size.py
src/capo_pipes/types/batch_container_overrides.py
src/capo_pipes/types/batch_depends_on.py
src/capo_pipes/types/batch_environment_variable.py
src/capo_pipes/types/batch_environment_variable_list.py
src/capo_pipes/types/batch_job_dependency.py
src/capo_pipes/types/batch_job_dependency_type.py
src/capo_pipes/types/batch_parameters_map.py
src/capo_pipes/types/batch_resource_requirement.py
src/capo_pipes/types/batch_resource_requirement_type.py
src/capo_pipes/types/batch_resource_requirements_list.py
src/capo_pipes/types/batch_retry_attempts.py
src/capo_pipes/types/batch_retry_strategy.py
src/capo_pipes/types/boolean.py
src/capo_pipes/types/capacity_provider.py
src/capo_pipes/types/capacity_provider_strategy.py
src/capo_pipes/types/capacity_provider_strategy_item.py
src/capo_pipes/types/capacity_provider_strategy_item_base.py
src/capo_pipes/types/capacity_provider_strategy_item_weight.py
src/capo_pipes/types/cloudwatch_log_group_arn.py
src/capo_pipes/types/cloudwatch_logs_log_destination.py
src/capo_pipes/types/cloudwatch_logs_log_destination_parameters.py
src/capo_pipes/types/create_pipe_request.py
src/capo_pipes/types/create_pipe_response.py
src/capo_pipes/types/database.py
src/capo_pipes/types/db_user.py
src/capo_pipes/types/dead_letter_config.py
src/capo_pipes/types/delete_pipe_request.py
src/capo_pipes/types/delete_pipe_response.py
src/capo_pipes/types/describe_pipe_request.py
src/capo_pipes/types/describe_pipe_response.py
src/capo_pipes/types/dimension_mapping.py
src/capo_pipes/types/dimension_mappings.py
src/capo_pipes/types/dimension_name.py
src/capo_pipes/types/dimension_value.py
src/capo_pipes/types/dimension_value_type.py
src/capo_pipes/types/dynamo_db_stream_start_position.py
src/capo_pipes/types/ecs_container_override.py
src/capo_pipes/types/ecs_container_override_list.py
src/capo_pipes/types/ecs_environment_file.py
src/capo_pipes/types/ecs_environment_file_list.py
src/capo_pipes/types/ecs_environment_file_type.py
src/capo_pipes/types/ecs_environment_variable.py
src/capo_pipes/types/ecs_environment_variable_list.py
src/capo_pipes/types/ecs_ephemeral_storage.py
src/capo_pipes/types/ecs_inference_accelerator_override.py
src/capo_pipes/types/ecs_inference_accelerator_override_list.py
src/capo_pipes/types/ecs_resource_requirement.py
src/capo_pipes/types/ecs_resource_requirement_type.py
src/capo_pipes/types/ecs_resource_requirements_list.py
src/capo_pipes/types/ecs_task_override.py
src/capo_pipes/types/endpoint_string.py
src/capo_pipes/types/ephemeral_storage_size.py
src/capo_pipes/types/epoch_time_unit.py
src/capo_pipes/types/error_message.py
src/capo_pipes/types/event_bridge_detail_type.py
src/capo_pipes/types/event_bridge_endpoint_id.py
src/capo_pipes/types/event_bridge_event_resource_list.py
src/capo_pipes/types/event_bridge_event_source.py
src/capo_pipes/types/event_pattern.py
src/capo_pipes/types/filter.py
src/capo_pipes/types/filter_criteria.py
src/capo_pipes/types/filter_list.py
src/capo_pipes/types/firehose_arn.py
src/capo_pipes/types/firehose_log_destination.py
src/capo_pipes/types/firehose_log_destination_parameters.py
src/capo_pipes/types/header_key.py
src/capo_pipes/types/header_parameters_map.py
src/capo_pipes/types/header_value.py
src/capo_pipes/types/include_execution_data.py
src/capo_pipes/types/include_execution_data_option.py
src/capo_pipes/types/input_template.py
src/capo_pipes/types/json_path.py
src/capo_pipes/types/kafka_bootstrap_servers.py
src/capo_pipes/types/kafka_topic_name.py
src/capo_pipes/types/kinesis_partition_key.py
src/capo_pipes/types/kinesis_stream_start_position.py
src/capo_pipes/types/kms_key_identifier.py
src/capo_pipes/types/launch_type.py
src/capo_pipes/types/limit_max10.py
src/capo_pipes/types/limit_max100.py
src/capo_pipes/types/limit_max10000.py
src/capo_pipes/types/limit_min1.py
src/capo_pipes/types/list_pipes_request.py
src/capo_pipes/types/list_pipes_response.py
src/capo_pipes/types/list_tags_for_resource_request.py
src/capo_pipes/types/list_tags_for_resource_response.py
src/capo_pipes/types/log_level.py
src/capo_pipes/types/log_stream_name.py
src/capo_pipes/types/maximum_batching_window_in_seconds.py
src/capo_pipes/types/maximum_record_age_in_seconds.py
src/capo_pipes/types/maximum_retry_attempts_esm.py
src/capo_pipes/types/measure_name.py
src/capo_pipes/types/measure_value.py
src/capo_pipes/types/measure_value_type.py
src/capo_pipes/types/message_deduplication_id.py
src/capo_pipes/types/message_group_id.py
src/capo_pipes/types/mq_broker_access_credentials.py
src/capo_pipes/types/mq_broker_queue_name.py
src/capo_pipes/types/msk_access_credentials.py
src/capo_pipes/types/msk_start_position.py
src/capo_pipes/types/multi_measure_attribute_mapping.py
src/capo_pipes/types/multi_measure_attribute_mappings.py
src/capo_pipes/types/multi_measure_attribute_name.py
src/capo_pipes/types/multi_measure_mapping.py
src/capo_pipes/types/multi_measure_mappings.py
src/capo_pipes/types/multi_measure_name.py
src/capo_pipes/types/network_configuration.py
src/capo_pipes/types/next_token.py
src/capo_pipes/types/on_partial_batch_item_failure_streams.py
src/capo_pipes/types/optional_arn.py
src/capo_pipes/types/path_parameter.py
src/capo_pipes/types/path_parameter_list.py
src/capo_pipes/types/pipe.py
src/capo_pipes/types/pipe_arn.py
src/capo_pipes/types/pipe_description.py
src/capo_pipes/types/pipe_enrichment_http_parameters.py
src/capo_pipes/types/pipe_enrichment_parameters.py
src/capo_pipes/types/pipe_list.py
src/capo_pipes/types/pipe_log_configuration.py
src/capo_pipes/types/pipe_log_configuration_parameters.py
src/capo_pipes/types/pipe_name.py
src/capo_pipes/types/pipe_source_active_mq_broker_parameters.py
src/capo_pipes/types/pipe_source_dynamo_db_stream_parameters.py
src/capo_pipes/types/pipe_source_kinesis_stream_parameters.py
src/capo_pipes/types/pipe_source_managed_streaming_kafka_parameters.py
src/capo_pipes/types/pipe_source_parameters.py
src/capo_pipes/types/pipe_source_rabbit_mq_broker_parameters.py
src/capo_pipes/types/pipe_source_self_managed_kafka_parameters.py
src/capo_pipes/types/pipe_source_sqs_queue_parameters.py
src/capo_pipes/types/pipe_state.py
src/capo_pipes/types/pipe_state_reason.py
src/capo_pipes/types/pipe_target_batch_job_parameters.py
src/capo_pipes/types/pipe_target_cloud_watch_logs_parameters.py
src/capo_pipes/types/pipe_target_ecs_task_parameters.py
src/capo_pipes/types/pipe_target_event_bridge_event_bus_parameters.py
src/capo_pipes/types/pipe_target_http_parameters.py
src/capo_pipes/types/pipe_target_invocation_type.py
src/capo_pipes/types/pipe_target_kinesis_stream_parameters.py
src/capo_pipes/types/pipe_target_lambda_function_parameters.py
src/capo_pipes/types/pipe_target_parameters.py
src/capo_pipes/types/pipe_target_redshift_data_parameters.py
src/capo_pipes/types/pipe_target_sage_maker_pipeline_parameters.py
src/capo_pipes/types/pipe_target_sqs_queue_parameters.py
src/capo_pipes/types/pipe_target_state_machine_parameters.py
src/capo_pipes/types/pipe_target_timestream_parameters.py
src/capo_pipes/types/placement_constraint.py
src/capo_pipes/types/placement_constraint_expression.py
src/capo_pipes/types/placement_constraint_type.py
src/capo_pipes/types/placement_constraints.py
src/capo_pipes/types/placement_strategies.py
src/capo_pipes/types/placement_strategy.py
src/capo_pipes/types/placement_strategy_field.py
src/capo_pipes/types/placement_strategy_type.py
src/capo_pipes/types/propagate_tags.py
src/capo_pipes/types/query_string_key.py
src/capo_pipes/types/query_string_parameters_map.py
src/capo_pipes/types/query_string_value.py
src/capo_pipes/types/reference_id.py
src/capo_pipes/types/requested_pipe_state.py
src/capo_pipes/types/requested_pipe_state_describe_response.py
src/capo_pipes/types/resource_arn.py
src/capo_pipes/types/role_arn.py
src/capo_pipes/types/s3_log_destination.py
src/capo_pipes/types/s3_log_destination_parameters.py
src/capo_pipes/types/s3_output_format.py
src/capo_pipes/types/sage_maker_pipeline_parameter.py
src/capo_pipes/types/sage_maker_pipeline_parameter_list.py
src/capo_pipes/types/sage_maker_pipeline_parameter_name.py
src/capo_pipes/types/sage_maker_pipeline_parameter_value.py
src/capo_pipes/types/secret_manager_arn.py
src/capo_pipes/types/secret_manager_arn_or_json_path.py
src/capo_pipes/types/security_group.py
src/capo_pipes/types/security_group_id.py
src/capo_pipes/types/security_group_ids.py
src/capo_pipes/types/security_groups.py
src/capo_pipes/types/self_managed_kafka_access_configuration_credentials.py
src/capo_pipes/types/self_managed_kafka_access_configuration_vpc.py
src/capo_pipes/types/self_managed_kafka_start_position.py
src/capo_pipes/types/single_measure_mapping.py
src/capo_pipes/types/single_measure_mappings.py
src/capo_pipes/types/sql.py
src/capo_pipes/types/sqls.py
src/capo_pipes/types/start_pipe_request.py
src/capo_pipes/types/start_pipe_response.py
src/capo_pipes/types/statement_name.py
src/capo_pipes/types/stop_pipe_request.py
src/capo_pipes/types/stop_pipe_response.py
src/capo_pipes/types/string.py
src/capo_pipes/types/string_list.py
src/capo_pipes/types/subnet.py
src/capo_pipes/types/subnet_id.py
src/capo_pipes/types/subnet_ids.py
src/capo_pipes/types/subnets.py
src/capo_pipes/types/tag.py
src/capo_pipes/types/tag_key.py
src/capo_pipes/types/tag_key_list.py
src/capo_pipes/types/tag_list.py
src/capo_pipes/types/tag_map.py
src/capo_pipes/types/tag_resource_request.py
src/capo_pipes/types/tag_resource_response.py
src/capo_pipes/types/tag_value.py
src/capo_pipes/types/time_field_type.py
src/capo_pipes/types/time_value.py
src/capo_pipes/types/timestamp.py
src/capo_pipes/types/timestamp_format.py
src/capo_pipes/types/untag_resource_request.py
src/capo_pipes/types/untag_resource_response.py
src/capo_pipes/types/update_pipe_request.py
src/capo_pipes/types/update_pipe_response.py
src/capo_pipes/types/update_pipe_source_active_mq_broker_parameters.py
src/capo_pipes/types/update_pipe_source_dynamo_db_stream_parameters.py
src/capo_pipes/types/update_pipe_source_kinesis_stream_parameters.py
src/capo_pipes/types/update_pipe_source_managed_streaming_kafka_parameters.py
src/capo_pipes/types/update_pipe_source_parameters.py
src/capo_pipes/types/update_pipe_source_rabbit_mq_broker_parameters.py
src/capo_pipes/types/update_pipe_source_self_managed_kafka_parameters.py
src/capo_pipes/types/update_pipe_source_sqs_queue_parameters.py
src/capo_pipes/types/uri.py
src/capo_pipes/types/validation_exception_field.py
src/capo_pipes/types/validation_exception_field_list.py
src/capo_pipes/types/version_value.py
src/capo_pipes/types/_prelude/blob.py
src/capo_pipes/types/_prelude/timestamp.py
tests/test_body.py
tests/test_sigv4.py