This repository was archived by the owner on Sep 30, 2026. It is now read-only.
1.2.0
Feature:
- Remove dependency on
AIRFLOW__CORE__ENABLE_XCOM_PICKLING. Users can set new environment variables, namelyAIRFLOW__ASTRO_SDK__XCOM_STORAGE_CONN_IDandAIRFLOW__ASTRO_SDK__XCOM_STORAGE_URLand use a custom XCOM backend namely,AstroCustomXcomBackendwhich enables the XCOM data to be saved to an S3 or GCS location. #795, #997 - Added OpenLineage support for
LoadFileOperator,AppendOperator,TransformOperatorandMergeOperator#898, #899, #902, #901 and #900 - Add
TransformFileOperatorthat- parses a SQL file with templating
- applies all needed parameters
- runs the SQL to return a table object to keep the
aql.transform_filefunction, the function can returnTransformFileOperator().outputin a similar fashion to the merge operator. #892
- Add the implementation for row count for
BaseTable. #1073
Improvement:
- Improved handling of snowflake identifiers for smooth experience with
dataframeandrun_raw_sqlandload_fileoperators. #917, #1098 - Fix
transform_fileto not depend ontransformdecorator #1004 - Set the CI to run and publish benchmark reports once a week #443
- Fix cyclic dependency and improve import time. Reduces the import time for
astro/databases/__init__.pyfrom 23.254 seconds to 0.062 seconds #1013
Docs
- Create GETTING_STARTED.md #1036
- Document the Open Lineage facets published by Astro Python SDK. #1086
- Documentation changes to specify permissions needed for running BigQuery jobs. #896
- Document the details on custom XCOM. #1100
- Document the benchmarking process. #1017
- Include a detailed description on the default Dataset concept in Astro Python SDK. #1092
Misc
- NFS volume mount in Kubernetes to test benchmarking from local to databases. #883