Workflow Automation

An automated pipeline that validates, processes, and reports on incoming records.

Automate your data quality workflow end to end.

from gdtest_sec_index_hero import validate, process, summarize

schema = {'value': int}
records = [{'value': 10}, {'value': 20}, {'value': 30}]

valid = [r for r in records if validate(schema, r)]
values = [r['value'] for r in valid]
clean = process(values, strict=True)
report = summarize(clean)
print(report)