wegamekinglc / calc-flow / 35669266485

94%

Build Type

push

github

Committed by web-flow

Commit Message

fix: DAL-296 DAL-297 validate Kafka decoder output

Normalize Python Kafka decoder output to the source's declared schema and
reject actual NULL values in non-nullable fields before downstream use.
Preserve schemas for zero-batch Arrow Tables so empty output can advance
the Kafka cursor without dropping zero-column row counts.

Document schema, metadata and empty-output behavior. Gate the native Kafka
test dependency behind connector-kafka and cover resolved feature graphs
with the existing shell-free command runner.

Closes DAL-296
Closes DAL-297

Coverage Stats

208 of 209 new or added lines in 1 file covered. (99.52%)

18 existing lines in 7 files now uncovered.

106289 of 114047 relevant lines covered (93.2%)

67875.14 hits per line