Hopefully we can write an Airflow replacement using this.