Runtime data integration system that empowers any data processing system to capture and query workflow provenance using data observability and code instrumentation.