Added
- Factored out common functionality in Python airflow integration @mobuchowski
- Added Airflow task run macro to expose task run id @collado-mike
Changed
- Refactored ValuesAverageExpectationParser to ValuesSumExpectationParser and ValuesCountExpectationParser @collado-mike
- Updated SparkListener to extend Spark's SparkListener abstract class @collado-mike
Fixed
- Use current project version in spark openlineage client @mobuchowski
- Rewrote LineageDao queries and LineageService for performance @collado-mike
- Updated lineage query to include new jobs that have no job version yet @collado-mike