ETL-811: migrate to pipeline v3

[PabloPardoGarcia]

No description provided.

[github-actions]

Test Coverage Report

File	Stmts	Miss	Cover	Missing
etl
__init__.py	6	0	100%
api_client.py	64	5	92%	70–73, 123
client.py	39	4	89%	59–61, 141
dlq.py	41	1	97%	70
errors.py	28	0	100%
pipeline.py	149	7	95%	353–356, 369, 425–426
tracking.py	26	0	100%
utils.py	49	1	97%	109
etl/models
__init__.py	10	0	100%
base.py	10	1	90%	9
config.py	34	8	76%	37, 40–41, 43–45, 47–48
data_types.py	80	0	100%
metadata.py	4	0	100%
pipeline.py	137	5	96%	58, 167, 207, 232, 263
resources.py	120	37	69%	31, 72–78, 88–95, 125–132, 142, 144–150, 167, 169, 172–174
sink.py	77	7	90%	36, 44, 46, 81, 83, 85, 87
source.py	14	0	100%
etl/models/sources
__init__.py	10	0	100%
kafka.py	102	1	99%	100
otlp.py	15	0	100%
etl/models/transforms
__init__.py	5	0	100%
deduplication.py	38	4	89%	17, 25, 47, 51
filter.py	15	1	93%	15
join.py	67	4	94%	55, 85, 95, 101
stateless_transformation.py	48	8	83%	48, 52, 56, 61, 73, 75, 77, 79
TOTAL	1188	94	92%

[github-actions]

Test Coverage Report

File	Stmts	Miss	Cover	Missing
glassflow/etl
__init__.py	6	0	100%
api_client.py	64	5	92%	70–73, 123
client.py	39	4	89%	59–61, 141
dlq.py	41	1	97%	70
errors.py	28	0	100%
pipeline.py	149	7	95%	353–356, 369, 425–426
tracking.py	26	0	100%
utils.py	49	1	97%	109
glassflow/etl/models
__init__.py	10	0	100%
base.py	10	1	90%	9
config.py	34	8	76%	37, 40–41, 43–45, 47–48
data_types.py	80	0	100%
metadata.py	4	0	100%
pipeline.py	137	5	96%	58, 167, 207, 232, 263
resources.py	120	37	69%	31, 72–78, 88–95, 125–132, 142, 144–150, 167, 169, 172–174
sink.py	77	7	90%	36, 44, 46, 81, 83, 85, 87
source.py	14	0	100%
glassflow/etl/models/sources
__init__.py	10	0	100%
kafka.py	102	1	99%	100
otlp.py	15	0	100%
glassflow/etl/models/transforms
__init__.py	5	0	100%
deduplication.py	38	4	89%	17, 25, 47, 51
filter.py	15	1	93%	15
join.py	67	4	94%	55, 85, 95, 101
stateless_transformation.py	48	8	83%	48, 52, 56, 61, 73, 75, 77, 79
TOTAL	1188	94	92%