ghga-de / hexkit

92%

main: 93%

LAST BUILD ON BRANCH 4.0.0

branch: 4.0.0

CHANGE BRANCH

x

Reset

Sync Branches

• 4.0.0
• 0.1.0
• 0.10.0
• 0.10.1
• 0.10.2
• 0.11.0
• 0.11.1
• 0.2.0
• 0.2.1
• 0.2.2
• 0.3.0
• 0.3.1
• 0.3.2
• 0.4.0
• 0.5.0
• 0.5.1
• 0.6.0
• 0.6.1
• 0.7.0
• 0.7.1
• 0.7.2
• 0.8.0
• 0.8.1
• 0.8.2
• 0.8.3
• 0.8.4
• 0.9.0
• 0.9.1
• 0.9.2
• 0.9.3
• 1.0.0
• 1.1.0
• 1.2.0
• 2.0.0
• 2.1.0
• 2.1.1
• 2.2.0
• 3.0.0
• 3.0.1
• 3.0.2
• 3.1.0
• 3.2.0
• 3.2.1
• 3.2.2
• 3.3.0
• 3.4.0
• 3.5.0
• 3.6.0
• 3.6.1
• 3.7.0
• 3.8.0
• 3.8.1
• 3.8.2
• 4.1.0
• 4.1.1
• 4.2.0
• 4.3.0
• 4.3.1
• 4.4.0
• 4.6.0
• 4.6.1
• 4.6.2
• 5.0.0
• 5.1.0
• 5.1.1
• 5.3.0
• 5.4.0
• 5.4.1
• 6.0.0
• 7.0.0
• 7.1.0
• 7.2.0
• 7.2.1
• backport/bucket_name_restriction
• buggy_otel_backport
• config_from_yaml_GSI-897
• dao-test-typehints
• db_based_dlq
• debug/federated-storage-tests
• di_resource_draft
• draft_constructable_typing_improvements
• eject_dependency_injector
• enable-ssl-for-kafka
• feature/abc_prot_GDEV-775
• feature/adaptive_part_size_GDEV-1402
• feature/add-message-to-correlation-context-error
• feature/add-package-data-GIM-453
• feature/add-py-typed-GSI-713
• feature/add-test-for-find-all
• feature/add_config_kafka_fixture_GDEV-1440
• feature/add_list_object_ids
• feature/akafka_testutils_GDEV-1210
• feature/async_dao_GDEV-1150
• feature/async_di_GDEV-845
• feature/async_protocols_GDEV-716
• feature/automate_dlq_topic_naming_GSI-1175
• feature/avoid_concurrent_copy_ops_GSI-1155
• feature/aync_constructable
• feature/backport-changes-in-v4
• feature/backport_copy_deduplication
• feature/basic_docs_GSI-541
• feature/basic_kafka_logging_GSI-473
• feature/better_dlqsub_init
• feature/bson_uuids_dates_GSI-1711
• feature/bucket_name_restriction
• feature/config_id_gen_GDEV-1204
• feature/configure_event_size_limit_GSI-939
• feature/content_md5_functionality
• feature/correlation_for_kafka_GSI-506
• feature/correlation_id_outbox_GSI-764
• feature/correlation_id_utilities_GSI-501
• feature/correlation_ids_GSI-xxx
• feature/custom_otel_tracer
• feature/dao-proto-GDEV-993
• feature/dao_val_GDEV-1141
• feature/db_based_dlq_GSI-1315
• feature/db_event_outbox_GSI-610
• feature/db_versioning_GSI-1462
• feature/delete_records_GSI-556
• feature/deprecate_daos_GSI-976
• feature/dlq_direct_process_GSI-1251
• feature/dlq_dry_run_GSI-1291
• feature/dlq_preview_GSI-1127
• feature/document_dlq
• feature/document_outbox_v_persistent_pub
• feature/document_tha
• feature/documentation_GSI-1598
• feature/documentation_eda
• feature/enable_testing_compacted_topics
• feature/event_id_GSI-1176
• feature/event_recorder_GDEV-1441
• feature/exc_info_dlq_header_GSI-1119
• feature/expand_translator_converter_GSI-1405
• feature/export-testutils
• feature/expose_event_header_testing_GSI-770
• feature/extend-overview
• feature/federated_s3_fixture_GSI-965
• feature/find_one_exception_GDEV-1406
• feature/finer_dao_error_handling_GSI-1005
• feature/finish_dlq_section
• feature/finish_outbox_v_persistent_GSI-1900
• feature/fix-typos
• feature/fix_correlation_id_from_str_GSI-2057
• feature/fix_destructor_problem_with_kafka_provider_GDEV-787
• feature/fix_id_in_find_all_GSI-190
• feature/get_content_length_GDEV-1597
• feature/get_metadata_GDEV-1593
• feature/handle-null-payload
• feature/improve-check-for-bucket-existence-GSI-1142
• feature/improve-empty-buckets-GSI-902
• feature/improve-mongo-provider-tests
• feature/improve-mongokafka-tests-GSI-988
• feature/improve-topic-clearing-GSI-885
• feature/improve_json_serialization
• feature/in_mem_prov_GDEV-715
• feature/inbound_prot_GDEV-714
• feature/inbound_protocol_GDEV-714
• feature/include-traceback-in-log-GSI-884
• feature/kafka_compression
• feature/kafka_compression_GSI-1669
• feature/kafka_event_ids_GSI-1713
• feature/kafka_ssl_pwd
• feature/log_all_config_GSI-546
• feature/logging_GSI-510
• feature/logging_suggestion
• feature/manual_kafka_commits_GSI-553
• feature/mem_prov_GDEV-715
• feature/merge-outbox-subscriber
• feature/mig_help_for_v6_GSI-1730
• feature/minor-update-event-subscriber
• feature/mock_dao_GSI-1905
• feature/mock_s3_fixture_GSI-1916
• feature/module_scoped_fixtures_GSI-270
• feature/mongo_dsn_GSI-952
• feature/mongo_timeout_GSI-987
• feature/mongodb_db_GDEV-1047
• feature/mongodb_timeout_GSI-987
• feature/more_otel_refactoring
• feature/move-package-data-config
• feature/move-package-data-to-manifest
• feature/multipart_copy_GDEV-1328
• feature/objstorage
• feature/opentelemetry
• feature/outbound_prot_GDEV-713
• feature/outbox_consumer_GSI-622
• feature/outbox_retry_headers_GSI-1405
• feature/patch_event_recorder_v3_GSI-691
• feature/patch_kafka_reset_GSI-691
• feature/persistent_publisher_GSI-1435
• feature/placeholder_documentation_GSI-1600
• feature/prepare-next-release
• feature/preview_dlq_events_GSI-1127
• feature/pydantic_v2_GSI-338
• feature/pymongo_async_GSI-1727
• feature/refactor_s3_testutils_GSI-762
• feature/remove_di_GSI-536
• feature/reverse_retry_names_GSI-1612
• feature/safe_log_formatting_GSI-1755
• feature/separate-container-fixtures-GSI-748
• feature/simplify_dao_api_GSI-789
• feature/split_fixtures_GSI-305
• feature/standard_provider_config_GDEV-1206
• feature/support-python-312
• feature/support-python313-gsi-1527
• feature/switch_to_abc_GDEV-775
• feature/test-py312-on-github
• feature/test_example_GDEV-946
• feature/test_py_versions_GSI-452
• feature/transaction_GDEV-1151
• feature/uniform_outbox_dao_GSI-924
• feature/universal-auth-adapter-GDEV-1663
• feature/update-asyncio-and-other-deps
• feature/update-base-imange-and-deps
• feature/update-pydantic
• feature/update-requests
• feature/update-template-and-dependencies
• feature/update-to-new-template
• feature/update_static_files
• feature/update_template
• feature/upgrade-aiokafka
• feature/upgrade_pytest_asyncio_GSI-534
• feature/use_secretstr_kafka_GSI-683
• feature/v5_safely_dump_logs_GSI-1756
• fix/Issue-with-sys-path-in-stream-calc-test
• fix/adapt-pypi-publishing
• fix/add_otel_setup_logging
• fix/always-add-traceback-if-configured-gsi-1415
• fix/boto_client_error_stacktrace
• fix/boto_pagination
• fix/bump_mypy
• fix/dao-publisher-inconsistencies
• fix/dev_install
• fix/export-mongokafka-classes
• fix/failing-federated-s3-tests
• fix/federateds3_test_blips_GSI-1125
• fix/file_info_paginator
• fix/fine_grained_otel_extras
• fix/get_by_id
• fix/harmonize_mypy_version
• fix/hotfix_release_GDEV-1092
• fix/isort_bump
• fix/issue-with-typing-extensions-460
• fix/json-object-definition
• fix/kafka-for-dev-container
• fix/list_multipart_uploads_pagination
• fix/minor-issues-with-fixtures
• fix/minor-things
• fix/no-hits-found-error
• fix/one_part_upload
• fix/opentelemetry_cleanup
• fix/opentelemetry_config
• fix/otel_distro_issues
• fix/pyenv-issues-and-some-more-GSI-750
• fix/raw_pymongo_on_duplicate
• fix/remove_buggy_otel_parts
• fix/remove_multipart_upload_existing_guard
• fix/remove_otel_distro
• fix/remove_unreliable_otel_wrapping
• fix/return-type-of-find-one
• fix/reusability_of_id_generator
• fix/roll_back_testcontainers
• fix/security-alert-9
• fix/set-correlation-id-in-db
• fix/spelling-in-log-message
• fix/testcontainers-version
• fix/typos
• fix/upper_bound_for_versions
• fix/use_generic_otel_exporter_dependency
• fix_federateds3_test_blips_GSI-1125
• fix_kafka_tests_GSI-793
• kafka_retry_v2_GSI-845
• main
• merge_from_main
• mongo_transaction_example
• multiple_object_storage_config_GSI-374
• otel_refactoring
• otel_test
• patch_pypi_publish
• setup_teardown_options
• suggestions-GDEV-1597
• temp-branch
• transition
• update_from_template_GSI-335
• update_kafka
• update_mem
• update_pypi_GSI-290
• update_tornado
• use_lock_file_pypi_publish
• v1
• v2
• v3
• v3-maintenance
• v3_support
• v4
• v6
• v7

Build # 13151969397

Build Type

push

github

Committed by web-flow

Commit Message

Use database for DLQ events (GSI-1315) (#154)

* Add DLQSubscriberProtocol

* Add kafka_dlq_topic with default of 'dlq'

* Remove KafkaDLQSubscriber

* Use KafkaEventSubscriber to handle DLQ reads

* Update tests and remove KafkaDLQSubscriber-specific cases

* Include convenient asdict() on ExtractedEventInfo

* Delimit event ID by comma and prepend service name

* Derive service name from event_id, not own field

* Only extract og topic header for events from retry topics

* Add comment, fix typo, tweak test assertion

Run Details

72 of 73 new or added lines in 3 files covered. (98.63%)

2 existing lines in 2 files now uncovered.

1994 of 2163 relevant lines covered (92.19%)

0.92 hits per line