Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/awslabs/amazon-s3-find-and-forget
/ endpoints
Endpoints
295 in github.com/awslabs/amazon-s3-find-and-forget
⨍
Functions
976
◇
Types & classes
14
↳
Endpoints
295
Route
create
helper.delete
backend/lambdas/custom_resources/wait_container_build.py:None
Route
create
helper.delete
backend/lambdas/custom_resources/redeploy_apigw.py:None
Route
delete
helper.delete
backend/lambdas/custom_resources/cleanup_repository.py:None
Route
delete
helper.delete
backend/lambdas/custom_resources/get_vpce_subnets.py:None
Route
delete
helper.delete
backend/lambdas/custom_resources/rerun_pipeline.py:None
Route
delete
helper.delete
backend/lambdas/custom_resources/cleanup_bucket.py:None
Route
delete
helper.delete
backend/lambdas/custom_resources/copy_build_artefact.py:None
Route
delete_data_mapper_handler
request_validator(load_schema("delete_data_mapper"))
backend/lambdas/data_mappers/handlers.py:None
Route
delete_s3_objects
retry( wait=wait_exponential(multiplier=1, min=1, max=10), stop=stop_after_attempt(10), retry=(ret
backend/ecs_tasks/delete_files/s3.py:None
Route
get_data_mapper_handler
request_validator(load_schema("get_data_mapper"))
backend/lambdas/data_mappers/handlers.py:None
Route
get_job_handler
request_validator(load_schema("get_job"))
backend/lambdas/jobs/handlers.py:None
Route
test_cse_kms_encrypted
patch.dict(os.environ, {"JobTable": "test"})
tests/unit/ecs_tasks/test_main.py:None
Route
test_deletes_for_receipt_handle
patch("backend.lambdas.tasks.delete_message.sqs")
tests/unit/tasks/test_delete_message.py:None
Route
test_error_handler
patch("backend.ecs_tasks.delete_files.main.emit_failure_event")
tests/unit/ecs_tasks/test_main.py:None
Route
test_happy_path_when_queue_not_empty
patch.dict(os.environ, {"JobTable": "test"})
tests/unit/ecs_tasks/test_main.py:None
Route
test_happy_path_when_queue_not_empty_for_compressed_json
patch.dict(os.environ, {"JobTable": "test"})
tests/unit/ecs_tasks/test_main.py:None
Route
test_it_abandons_when_any_query_fails_and_no_running_in_current_loop
patch("backend.lambdas.tasks.work_query_queue.load_execution")
tests/unit/tasks/test_work_query_queue.py:None
Route
test_it_abandons_when_previous_loop_found_failure
patch("backend.lambdas.tasks.work_query_queue.load_execution")
tests/unit/tasks/test_work_query_queue.py:None
Route
test_it_accepts_start_at_earliest_watermark
patch("backend.lambdas.jobs.handlers.table")
tests/unit/apis/test_job.py:None
Route
test_it_adds_batch_to_queue
patch("backend.lambdas.queue.handlers.deletion_queue_table")
tests/unit/apis/test_queue.py:None
Route
test_it_adds_composite_to_queue
patch("backend.lambdas.queue.handlers.deletion_queue_table")
tests/unit/apis/test_queue.py:None
Route
test_it_adds_to_queue
patch("backend.lambdas.queue.handlers.deletion_queue_table")
tests/unit/apis/test_queue.py:None
Route
test_it_applies_expiry
patch("backend.lambdas.queue.handlers.bucket_count", 1)
tests/unit/apis/test_queue.py:None
Route
test_it_applies_filters
patch("backend.lambdas.jobs.handlers.table")
tests/unit/apis/test_job.py:None
Route
test_it_applies_settings_when_saving
patch("backend.ecs_tasks.delete_files.s3.get_requester_payment")
tests/unit/ecs_tasks/test_s3.py:None
Route
test_it_applies_time_delta
patch("boto_utils.datetime")
tests/unit/lambda_layers/test_boto_utils.py:None
Route
test_it_assumes_role
patch.dict(os.environ, {"JobTable": "test"})
tests/unit/ecs_tasks/test_main.py:None
Route
test_it_assumes_role_for_session_where_given
patch("boto_utils.boto3")
tests/unit/lambda_layers/test_boto_utils.py:None
Route
test_it_builds_matches_grouped_by_column_composite
patch("backend.ecs_tasks.delete_files.main.fetch_manifest")
tests/unit/ecs_tasks/test_main.py:None
Route
test_it_builds_matches_grouped_by_column_mixed
patch("backend.ecs_tasks.delete_files.main.fetch_manifest")
tests/unit/ecs_tasks/test_main.py:None
Route
test_it_builds_matches_grouped_by_column_simple
patch("backend.ecs_tasks.delete_files.main.fetch_manifest")
tests/unit/ecs_tasks/test_main.py:None
Route
test_it_caches_manifests
patch("backend.ecs_tasks.delete_files.s3.fetch_job_manifest")
tests/unit/ecs_tasks/test_s3.py:None
Route
test_it_cancels_deletions
patch("backend.lambdas.queue.handlers.running_job_exists")
tests/unit/apis/test_queue.py:None
Route
test_it_cleans_up_on_forget_complete
patch("backend.lambdas.jobs.stream_processor.process_job", Mock(return_value=None))
tests/unit/jobs/test_stream_processor.py:None
Route
test_it_clears_completed_from_sqs
patch("backend.lambdas.tasks.work_query_queue.sqs")
tests/unit/tasks/test_work_query_queue.py:None
Route
test_it_clears_queue
patch("backend.lambdas.jobs.stream_processor.q_table.batch_writer")
tests/unit/jobs/test_stream_processor.py:None
Route
test_it_copies_file
patch("backend.lambdas.custom_resources.copy_build_artefact.s3_client")
tests/unit/crs/test_cr_copy_build_artefact.py:None
Route
test_it_creates_data_mapper
patch("backend.lambdas.data_mappers.handlers.table")
tests/unit/data_mappers/test_data_mappers.py:None
Route
test_it_defaults_emiiter_id
patch("backend.lambdas.tasks.emit_event.emit_event")
tests/unit/tasks/test_emit_event.py:None
Route
test_it_defaults_task_id_if_env_variable_not_set
patch("os.getenv", MagicMock(return_value=None))
tests/unit/ecs_tasks/test_events.py:None
Route
test_it_defaults_task_id_if_generic_error
patch("os.getenv", MagicMock(return_value="http://metadatauri/path"))
tests/unit/ecs_tasks/test_events.py:None
Route
test_it_defaults_task_id_if_malformed_response
patch("os.getenv", MagicMock(return_value="http://metadatauri/path"))
tests/unit/ecs_tasks/test_events.py:None
Route
test_it_defaults_task_id_if_urlerror
patch("os.getenv", MagicMock(return_value="http://metadatauri/path"))
tests/unit/ecs_tasks/test_events.py:None
Route
test_it_defaults_wait_duration
patch("backend.lambdas.tasks.work_query_queue.sf_client")
tests/unit/tasks/test_work_query_queue.py:None
Route
test_it_delegates_to_cr_helper
patch("backend.lambdas.custom_resources.cleanup_bucket.helper")
tests/unit/crs/test_cr_cleanup_bucket.py:None
Route
test_it_delegates_to_cr_helper
patch("backend.lambdas.custom_resources.rerun_pipeline.helper")
tests/unit/crs/test_cr_rerun_pipeline.py:None
Route
test_it_delegates_to_cr_helper
patch("backend.lambdas.custom_resources.wait_container_build.helper")
tests/unit/crs/test_cr_wait_container_build.py:None
Route
test_it_delegates_to_cr_helper
patch("backend.lambdas.custom_resources.get_vpce_subnets.helper")
tests/unit/crs/test_cr_get_vpce_subnets.py:None
Route
test_it_delegates_to_cr_helper
patch("backend.lambdas.custom_resources.copy_build_artefact.helper")
tests/unit/crs/test_cr_copy_build_artefact.py:None
Route
test_it_delegates_to_cr_helper
patch("backend.lambdas.custom_resources.redeploy_apigw.helper")
tests/unit/crs/test_cr_redeploy_apigw.py:None
Route
test_it_delegates_to_cr_helper
patch("backend.lambdas.custom_resources.cleanup_repository.helper")
tests/unit/crs/test_cr_cleanup_repository.py:None
Route
test_it_deletes_data_mapper
patch( "backend.lambdas.data_mappers.handlers.running_job_exists", Mock(return_value=False) )
tests/unit/data_mappers/test_data_mappers.py:None
Route
test_it_deletes_from_json_file
patch("backend.ecs_tasks.delete_files.main.delete_matches_from_json_file")
tests/unit/ecs_tasks/test_main.py:None
Route
test_it_deletes_from_parquet_file
patch("backend.ecs_tasks.delete_files.main.delete_matches_from_json_file")
tests/unit/ecs_tasks/test_main.py:None
Route
test_it_deletes_old_versions
patch("backend.ecs_tasks.delete_files.s3.paginate")
tests/unit/ecs_tasks/test_s3.py:None
Route
test_it_determines_basic_statuses
patch("backend.lambdas.jobs.status_updater.job_has_errors", Mock(return_value=False))
tests/unit/jobs/test_status_updater.py:None
Route
test_it_determines_completed_with_errors
patch("backend.lambdas.jobs.status_updater.job_has_errors", Mock(return_value=True))
tests/unit/jobs/test_status_updater.py:None
Route
test_it_determines_job_does_not_have_errors_for_failed_object_updates
patch("backend.lambdas.jobs.status_updater.table")
tests/unit/jobs/test_status_updater.py:None
Route
test_it_determines_job_has_errors_for_failed_object_updates
patch("backend.lambdas.jobs.status_updater.table")
tests/unit/jobs/test_status_updater.py:None
Route
test_it_determines_job_has_errors_for_failed_queries
patch("backend.lambdas.jobs.status_updater.table")
tests/unit/jobs/test_status_updater.py:None
Route
test_it_does_not_emit_skipped_event_for_non_failures
patch("backend.lambdas.jobs.stream_processor.process_job", Mock(return_value=None))
tests/unit/jobs/test_stream_processor.py:None
Route
test_it_does_not_ignore_not_found_error_by_default
patch.dict(os.environ, {"JobTable": "test"})
tests/unit/ecs_tasks/test_main.py:None
Route
test_it_does_not_override_user_supplied_endpoint_url
patch("backend.ecs_tasks.delete_files.main.boto3")
tests/unit/ecs_tasks/test_main.py:None
Route
test_it_does_not_return_watermark_if_last_page_reached_on_complete_job
patch("backend.lambdas.jobs.handlers.table")
tests/unit/apis/test_job.py:None
Route
test_it_does_not_trigger_deployment_if_not_required
patch("backend.lambdas.custom_resources.redeploy_apigw.api_client")
tests/unit/crs/test_cr_redeploy_apigw.py:None
Route
test_it_does_not_trigger_execution_if_not_required
patch("backend.lambdas.custom_resources.rerun_pipeline.pipe_client")
tests/unit/crs/test_cr_rerun_pipeline.py:None
Route
test_it_does_not_update_status_if_stats_fails
patch("backend.lambdas.jobs.stream_processor.is_operation", Mock(return_value=True))
tests/unit/jobs/test_stream_processor.py:None
Route
test_it_does_nothing_on_create
patch("backend.lambdas.custom_resources.cleanup_bucket.s3")
tests/unit/crs/test_cr_cleanup_bucket.py:None
Route
test_it_does_nothing_on_create
patch("backend.lambdas.custom_resources.redeploy_apigw.api_client")
tests/unit/crs/test_cr_redeploy_apigw.py:None
Route
test_it_does_nothing_on_create
patch("backend.lambdas.custom_resources.cleanup_repository.ecr_client")
tests/unit/crs/test_cr_cleanup_repository.py:None
Route
test_it_does_nothing_on_delete
patch("backend.lambdas.custom_resources.rerun_pipeline.pipe_client")
tests/unit/crs/test_cr_rerun_pipeline.py:None
Route
test_it_does_nothing_on_delete
patch("backend.lambdas.custom_resources.get_vpce_subnets.ec2_client")
tests/unit/crs/test_cr_get_vpce_subnets.py:None
Route
test_it_does_nothing_on_delete
patch("backend.lambdas.custom_resources.copy_build_artefact.s3_client")
tests/unit/crs/test_cr_copy_build_artefact.py:None
Route
test_it_doesnt_change_message_visibility_when_rollback_fails
patch("backend.ecs_tasks.delete_files.main.sanitize_message")
tests/unit/ecs_tasks/test_main.py:None
Route
test_it_doesnt_retry_non_retriable_fn
patch("time.sleep")
tests/unit/ecs_tasks/test_utils.py:None
Route
test_it_doesnt_retry_success_fn
patch("time.sleep")
tests/unit/ecs_tasks/test_utils.py:None
Route
test_it_emits_deletions
patch("backend.ecs_tasks.delete_files.events.emit_event")
tests/unit/ecs_tasks/test_events.py:None
Route
test_it_emits_event_for_cleanup_error
patch("backend.lambdas.jobs.stream_processor.process_job", Mock(return_value=None))
tests/unit/jobs/test_stream_processor.py:None
Route
test_it_emits_failed_deletions
patch("backend.ecs_tasks.delete_files.events.emit_event")
tests/unit/ecs_tasks/test_events.py:None
Route
test_it_emits_failed_rollback
patch("backend.ecs_tasks.delete_files.events.emit_event")
tests/unit/ecs_tasks/test_events.py:None
Route
test_it_emits_skipped_event_for_failures
patch("backend.lambdas.jobs.stream_processor.process_job", Mock(return_value=None))
tests/unit/jobs/test_stream_processor.py:None
Route
test_it_emits_skips
patch("backend.ecs_tasks.delete_files.events.emit_event")
tests/unit/ecs_tasks/test_events.py:None
Route
test_it_errors_if_job_not_found
patch("backend.lambdas.jobs.handlers.table")
tests/unit/apis/test_job.py:None
Route
test_it_errors_when_version_to_not_found_after_retries
patch("time.sleep")
tests/unit/ecs_tasks/test_s3.py:None
Route
test_it_executes_queries
patch("backend.lambdas.tasks.execute_query.client")
tests/unit/tasks/test_execute_query.py:None
Route
test_it_fetches_deletion_queue_from_ddb
patch("backend.lambdas.tasks.generate_queries.deserialize_item")
tests/unit/tasks/test_generate_queries.py:None
Route
test_it_fetches_deserialized_data_mappers
patch("backend.lambdas.tasks.generate_queries.deserialize_item")
tests/unit/tasks/test_generate_queries.py:None
Route
test_it_fetches_s3_manifest
patch("boto_utils.s3")
tests/unit/lambda_layers/test_boto_utils.py:None
Route
test_it_fetches_task_id_from_metadata_uri
patch("os.getenv", MagicMock(return_value="http://metadatauri/path"))
tests/unit/ecs_tasks/test_events.py:None
Route
test_it_filters_users_from_non_applicable_tables
patch("backend.lambdas.tasks.generate_queries.s3.Bucket")
tests/unit/tasks/test_generate_queries.py:None
Route
test_it_generates_new_parquet_file_without_matches
patch("backend.ecs_tasks.delete_files.parquet_handler.load_parquet")
tests/unit/ecs_tasks/test_parquet.py:None
Route
test_it_generates_queries_writes_manifests_populates_queue_and_returns_result
patch("backend.lambdas.tasks.generate_queries.write_partitions")
tests/unit/tasks/test_generate_queries.py:None
Route
test_it_gets_acl_args
patch("backend.ecs_tasks.delete_files.s3.get_requester_payment")
tests/unit/ecs_tasks/test_s3.py:None
Route
test_it_gets_data_mapper
patch("backend.lambdas.data_mappers.handlers.table")
tests/unit/data_mappers/test_data_mappers.py:None
Route
test_it_gets_data_mapper_not_found
patch("backend.lambdas.data_mappers.handlers.table")
tests/unit/data_mappers/test_data_mappers.py:None
Route
test_it_gets_details_for_table
patch("backend.lambdas.data_mappers.handlers.glue_client")
tests/unit/data_mappers/test_data_mappers.py:None
Route
test_it_gets_existing_s3_locations
patch("backend.lambdas.data_mappers.handlers.table")
tests/unit/data_mappers/test_data_mappers.py:None
Route
test_it_gets_existing_s3_locations_excluding_current_data_mapper_id
patch("backend.lambdas.data_mappers.handlers.table")
tests/unit/data_mappers/test_data_mappers.py:None
Route
test_it_gets_job_expiry
patch("boto_utils.table")
tests/unit/lambda_layers/test_boto_utils.py:None
Route
test_it_gracefully_handles_change_message_visibility_failure
patch("backend.ecs_tasks.delete_files.main.emit_failure_event")
tests/unit/ecs_tasks/test_main.py:None
next →
1–100 of 295, ranked by callers