uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r678402962
##
File path: airflow/api_connexion/endpoints/dag_run_endpoint.py
##
@@ -242,16 +242,23 @@ def post_dag_run(dag_id, session):
except ValidationErr
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r678403607
##
File path: airflow/models/dag.py
##
@@ -596,23 +697,17 @@ def get_run_dates(self, start_date, end_date=None, *,
align: bool = True):
:retu
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r678404313
##
File path: airflow/models/dag.py
##
@@ -2403,6 +2507,24 @@ def __init__(self, concurrency=None, **kwargs):
def __repr__(self):
return
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r678828040
##
File path: airflow/models/dag.py
##
@@ -112,6 +113,51 @@ def get_last_dagrun(dag_id, session,
include_externally_triggered=False):
return quer
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r678836464
##
File path: airflow/www/views.py
##
@@ -1537,11 +1537,12 @@ def trigger(self, session=None):
'airflow/trigger.html', dag_id=dag_
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r678836464
##
File path: airflow/www/views.py
##
@@ -1537,11 +1537,12 @@ def trigger(self, session=None):
'airflow/trigger.html', dag_id=dag_
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r678836464
##
File path: airflow/www/views.py
##
@@ -1537,11 +1537,12 @@ def trigger(self, session=None):
'airflow/trigger.html', dag_id=dag_
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r678841333
##
File path: airflow/timetables/interval.py
##
@@ -43,6 +43,13 @@ def __eq__(self, other: Any) -> bool:
def validate(self) -> None:
self
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r678841333
##
File path: airflow/timetables/interval.py
##
@@ -43,6 +43,13 @@ def __eq__(self, other: Any) -> bool:
def validate(self) -> None:
self
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r678841333
##
File path: airflow/timetables/interval.py
##
@@ -43,6 +43,13 @@ def __eq__(self, other: Any) -> bool:
def validate(self) -> None:
self
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r679613989
##
File path: airflow/models/dag.py
##
@@ -596,23 +649,17 @@ def get_run_dates(self, start_date, end_date=None, *,
align: bool = True):
:retu
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r679619000
##
File path: airflow/jobs/backfill_job.py
##
@@ -755,8 +759,13 @@ def _execute(self, session=None):
start_date = self.bf_start_date
-
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r679619712
##
File path: airflow/models/taskinstance.py
##
@@ -1530,21 +1532,25 @@ def get_template_context(self, session=None) -> Context:
integrate_mac
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r679620135
##
File path: airflow/models/taskinstance.py
##
@@ -1670,37 +1667,97 @@ def get(
except AirflowNotFoundException:
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r679620955
##
File path: airflow/timetables/base.py
##
@@ -79,6 +74,18 @@ def interval(cls, start: DateTime, end: DateTime) ->
"DagRunInfo":
"""
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r679621592
##
File path: airflow/models/taskinstance.py
##
@@ -1670,37 +1667,97 @@ def get(
except AirflowNotFoundException:
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r679734779
##
File path:
airflow/migrations/versions/142555e44c17_add_data_interval_start_end_to_dagrun.py
##
@@ -0,0 +1,61 @@
+#
+# Licensed to the Apache Softw
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r679746669
##
File path: airflow/models/taskinstance.py
##
@@ -1530,21 +1532,25 @@ def get_template_context(self, session=None) -> Context:
integrate_mac
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r681400265
##
File path: airflow/api_connexion/endpoints/dag_run_endpoint.py
##
@@ -242,21 +243,29 @@ def post_dag_run(dag_id, session):
except ValidationErr
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r683384487
##
File path: docs/apache-airflow/macros-ref.rst
##
@@ -35,28 +35,23 @@ in all templates
= =
uranusjr commented on a change in pull request #16352:
URL: https://github.com/apache/airflow/pull/16352#discussion_r684102232
##
File path: airflow/models/dag.py
##
@@ -537,30 +540,31 @@ def next_dagrun_info(
:param date_last_automated_dagrun: The ``max(execution_date
21 matches
Mail list logo
