Skip to content

[Exceptions] Add error mapper extension for plugins#464

Open
george-zubrienko wants to merge 4 commits into
mainfrom
error-mapper
Open

[Exceptions] Add error mapper extension for plugins#464
george-zubrienko wants to merge 4 commits into
mainfrom
error-mapper

Conversation

@george-zubrienko

@george-zubrienko george-zubrienko commented Jun 22, 2026

Copy link
Copy Markdown
Contributor

Closes #415

@github-actions

github-actions Bot commented Jun 22, 2026

Copy link
Copy Markdown

File Coverage
All files 70%
extensions/ZExtensions.scala 17%
logging/ZIOLogAnnotations.scala 78%
models/app/BaseStreamContext.scala 20%
models/app/PluginStreamContext.scala 0%
models/app/PluginStreamContext.scala 0%
models/app/PluginStreamContext.scala 0%
models/batches/BlobBatchCommons.scala 70%
models/batches/SynapseLink.scala 0%
models/batches/SqlServerChangeTracking.scala 0%
models/batches/SynapseLink.scala 79%
models/batches/SynapseLink.scala 68%
models/batches/SqlServerChangeTracking.scala 79%
models/batches/UpsertBlob.scala 78%
models/batches/UpsertBlob.scala 0%
models/batches/SqlServerChangeTracking.scala 0%
models/batches/UpsertBlob.scala 0%
models/cdm/SimpleCdmModel.scala 88%
models/cdm/CdmParser.scala 90%
models/cdm/CdmParser.scala 97%
models/ddl/CreateTableRequest.scala 80%
models/maintenance/JdbcSnapshotExpirationRequest.scala 50%
models/maintenance/JdbcOrphanFilesExpirationRequest.scala 50%
models/maintenance/JdbcAnalyzeRequest.scala 30%
models/maintenance/JdbcOptimizationRequest.scala 50%
models/queries/MergeQuerySegment.scala 90%
models/queries/MergeQuerySegment.scala 0%
models/queries/MergeQuery.scala 80%
models/queries/DefaultShardCommitQuery.scala 0%
models/queries/MergeQuerySegment.scala 94%
models/queries/backfill/blob/BlobShardCommitQuery.scala 0%
models/queries/backfill/blob/BlobShardStageQuery.scala 0%
models/queries/backfill/mssql/MsSqlShardCommitQuery.scala 0%
models/queries/backfill/mssql/MsSqlShardStageQuery.scala 0%
models/queries/backfill/synapse/SynapseLinkShardStageQuery.scala 0%
models/queries/backfill/synapse/SynapseLinkShardCommitQuery.scala 0%
models/schemas/ArcaneSchema.scala 84%
models/schemas/ArcaneSchema.scala 51%
models/schemas/ArcaneSchema.scala 62%
models/schemas/ArcaneSchema.scala 60%
models/schemas/ArcaneSchema.scala 0%
models/schemas/DataCell.scala 0%
models/schemas/ArcaneSchema.scala 71%
models/serialization/ZIODurationRW.scala 0%
models/serialization/FlowRateRW.scala 68%
models/serialization/AdlsStoragePathRW.scala 0%
models/serialization/JavaDurationRW.scala 0%
models/serialization/S3RegionRW.scala 0%
models/serialization/UriRW.scala 0%
models/settings/FieldSelectionRuleSettings.scala 96%
models/settings/TableNaming.scala 65%
models/settings/TablePropertiesSettings.scala 86%
models/settings/azure/AzureStorageConnectionSettings.scala 66%
models/settings/azure/AzureStorageConnectionSettings.scala 66%
models/settings/azure/AzureStorageConnectionSettings.scala 83%
models/settings/database/JdbcConnectionExtensions.scala 69%
models/settings/iceberg/DefaultIcebergStagingSettings.scala 0%
models/settings/mssql/MsSqlServerConnectionSettings.scala 0%
models/settings/sink/DefaultIcebergSinkSettings.scala 0%
models/settings/sources/blob/ParquetBlobSourceSettings.scala 0%
models/settings/sources/blob/JsonBlobSourceSettings.scala 0%
models/settings/staging/JdbcCredentialType.scala 0%
models/settings/staging/JdbcMergeServiceClientSettings.scala 0%
models/settings/staging/JdbcMergeServiceClientSettings.scala 0%
models/settings/staging/JdbcCredentialType.scala 48%
models/settings/staging/JdbcMergeServiceClientSettings.scala 71%
models/settings/streaming/ThroughputSettings.scala 89%
models/sharding/SourceShard.scala 0%
services/app/PosixStreamLifetimeService.scala 0%
services/app/GenericStreamRunnerService.scala 89%
services/backfill/DefaultBackfillStateManager.scala 85%
services/backfill/DefaultBackfillMergeStreamDataProvider.scala 0%
services/backfill/processors/ShardStagingProcessor.scala 82%
services/backfill/processors/BackfillCompletionProcessor.scala 90%
services/blobsource/DefaultS3Reader.scala 0%
services/blobsource/backfill/BlobBackfillSourceDataProvider.scala 51%
services/blobsource/backfill/BlobSourceShardFactory.scala 0%
services/blobsource/backfill/BlobSourceBackfillMergeStreamDataProvider.scala 0%
services/blobsource/backfill/BlobShardedBackfillStreamDataProvider.scala 0%
services/blobsource/providers/BlobSourceDataProvider.scala 75%
services/blobsource/providers/BlobSourceStreamingDataProvider.scala 71%
services/blobsource/readers/listing/BlobListingSource.scala 93%
services/blobsource/readers/listing/BlobListingParquetSource.scala 58%
services/blobsource/readers/listing/BlobListingJsonSource.scala 83%
services/blobsource/readers/listing/BlobListingCsvSource.scala 0%
services/blobsource/versioning/BlobSourceWatermark.scala 92%
services/blobsource/versioning/UpsertBlobStagedBatchFactory.scala 0%
services/bootstrap/DefaultStreamBootstrapper.scala 66%
services/filters/FieldsFilteringService.scala 91%
services/filters/ColumnSummaryFieldsFilteringService.scala 86%
services/iceberg/SchemaConversions.scala 0%
services/iceberg/SchemaConversions.scala 16%
services/iceberg/IcebergCatalogCredential.scala 60%
services/iceberg/SchemaConversions.scala 86%
services/iceberg/IcebergEntityManager.scala 61%
services/iceberg/SchemaConversions.scala 87%
services/iceberg/IcebergS3CatalogWriter.scala 95%
services/iceberg/IcebergTablePropertyManager.scala 72%
services/iceberg/IcebergCatalogFactory.scala 99%
services/iceberg/interop/JsonScanner.scala 82%
services/iceberg/interop/ParquetScanner.scala 80%
services/iceberg/interop/ParquetInputStreamAdapter.scala 75%
services/merging/JdbcMergeServiceClient.scala 36%
services/merging/cleanup/CatalogDisposeServiceClient.scala 90%
services/metrics/GlobalMetricTagProvider.scala 45%
services/metrics/DataDog.scala 0%
services/mssql/MsSqlStagedBatchFactory.scala 0%
services/mssql/MsSqlDataProvider.scala 54%
services/mssql/MsSqlExtensions.scala 74%
services/mssql/MsSqlStreamingDataProvider.scala 69%
services/mssql/QueryProvider.scala 69%
services/mssql/backfill/MsSqlBackfillSourceDataProvider.scala 69%
services/mssql/backfill/MsSqlBackfillMergeStreamDataProvider.scala 0%
services/mssql/backfill/MsSqlShardedBackfillStreamDataProvider.scala 0%
services/mssql/backfill/MsSqlShardFactory.scala 0%
services/mssql/base/MsSqlStreamingSource.scala 78%
services/mssql/query/LazyQueryResult.scala 84%
services/mssql/query/ScalarQueryResult.scala 65%
services/mssql/query/LazyQueryResult.scala 65%
services/naming/DefaultNameGenerator.scala 92%
services/storage/models/azure/AzureModelConversions.scala 98%
services/storage/models/azure/AdlsStoragePath.scala 82%
services/storage/models/base/StoredBlob.scala 85%
services/storage/models/s3/S3StoragePath.scala 80%
services/storage/models/s3/S3ClientSettings.scala 83%
services/storage/services/azure/AzureBlobStorageReader.scala 77%
services/storage/services/s3/S3BlobStorageReader.scala 66%
services/streaming/base/DefaultSourceDataProvider.scala 97%
services/streaming/base/SourceWatermark.scala 0%
services/streaming/base/SourceWatermark.scala 87%
services/streaming/base/DefaultStreamDataProvider.scala 73%
services/streaming/processors/batch_processors/WatermarkProcessingExtensions.scala 85%
services/streaming/processors/batch_processors/maintenance/TargetMaintenanceProcessor.scala 72%
services/streaming/processors/batch_processors/streaming/DisposeBatchProcessor.scala 79%
services/streaming/processors/batch_processors/streaming/SchemaMigrationProcessor.scala 19%
services/streaming/processors/transformers/StagingProcessor.scala 96%
services/streaming/throughput/MemoryBoundShaper.scala 74%
services/streaming/throughput/StaticShaper.scala 0%
services/streaming/throughput/base/ThroughputShaperBuilder.scala 50%
services/synapse/SynapseAzureBlobReaderExtensions.scala 97%
services/synapse/SynapseLinkStreamingDataProvider.scala 71%
services/synapse/SynapseBatchFactory.scala 0%
services/synapse/SynapseEntitySchemaProvider.scala 84%
services/synapse/backfill/SynapseShardFactory.scala 0%
services/synapse/backfill/SynapseBackfillSourceDataProvider.scala 84%
services/synapse/backfill/SynapseBackfillMergeStreamDataProvider.scala 0%
services/synapse/backfill/SynapseShardedBackfillStreamDataProvider.scala 0%
services/synapse/base/SynapseLinkDataProvider.scala 75%
services/synapse/base/SynapseLinkStreamingSource.scala 61%
services/synapse/versioning/SynapseWatermark.scala 83%
utils/SqlUtils.scala 0%
utils/SqlUtils.scala 48%
utils/CollectionUtils.scala 0%

Minimum allowed coverage is 40%

Generated by 🐒 cobertura-action against fdab0d2

@george-zubrienko george-zubrienko marked this pull request as ready for review June 23, 2026 07:27
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Support exception re-mapping for transient failures

2 participants