Commit 41be3a72 authored by Douwe Maan's avatar Douwe Maan

Immediately create DAG for every scheduled pipeline

parent acc5bf16
# Changelog
## 0.3
- [#1](https://gitlab.com/meltano/files-airflow/-/issues/1) Immediately create DAG for every scheduled pipeline, without waiting until a manual run has succeeded
......@@ -42,12 +42,6 @@ for schedule in schedules:
)
continue
if not schedule["last_successful_run_ended_at"]:
logging.info(
f"No DAG created for schedule '{schedule['name']}' because it hasn't had a successful (manual) run yet."
)
continue
args = DEFAULT_ARGS.copy()
if schedule["start_date"]:
args["start_date"] = schedule["start_date"]
......
......@@ -2,7 +2,7 @@ from setuptools import setup, find_packages
setup(
name="files-airflow",
version="0.2",
version="0.3",
description="Meltano project files for Airflow",
packages=find_packages(),
package_data={"bundle": ["orchestrate/dags/meltano.py"]},
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment