vincbeck commented on code in PR #28900:
URL: https://github.com/apache/airflow/pull/28900#discussion_r1532079650
##
airflow/models/taskinstance.py:
##
@@ -1692,69 +2411,14 @@ def signal_handler(signum, frame):
Stats.incr("operator_successes", tags={**self.stats_tags, "
potiuk commented on code in PR #28900:
URL: https://github.com/apache/airflow/pull/28900#discussion_r1531673185
##
airflow/models/taskinstance.py:
##
@@ -1692,69 +2411,14 @@ def signal_handler(signum, frame):
Stats.incr("operator_successes", tags={**self.stats_tags, "ta
vandonr commented on code in PR #28900:
URL: https://github.com/apache/airflow/pull/28900#discussion_r1526277558
##
airflow/models/taskinstance.py:
##
@@ -1692,69 +2411,14 @@ def signal_handler(signum, frame):
Stats.incr("operator_successes", tags={**self.stats_tags, "t
vandonr commented on code in PR #28900:
URL: https://github.com/apache/airflow/pull/28900#discussion_r1526276182
##
airflow/models/taskinstance.py:
##
@@ -375,6 +379,795 @@ def _creator_note(val):
return TaskInstanceNote(*val)
+def _execute_task(task_instance, conte
potiuk commented on code in PR #28900:
URL: https://github.com/apache/airflow/pull/28900#discussion_r1429319698
##
airflow/models/dag.py:
##
@@ -1383,8 +1384,43 @@ def normalized_schedule_interval(self) ->
ScheduleInterval:
_schedule_interval = self.schedule_interv
potiuk commented on code in PR #28900:
URL: https://github.com/apache/airflow/pull/28900#discussion_r1429319698
##
airflow/models/dag.py:
##
@@ -1383,8 +1384,43 @@ def normalized_schedule_interval(self) ->
ScheduleInterval:
_schedule_interval = self.schedule_interv
potiuk commented on code in PR #28900:
URL: https://github.com/apache/airflow/pull/28900#discussion_r1429319698
##
airflow/models/dag.py:
##
@@ -1383,8 +1384,43 @@ def normalized_schedule_interval(self) ->
ScheduleInterval:
_schedule_interval = self.schedule_interv
vincbeck commented on code in PR #28900:
URL: https://github.com/apache/airflow/pull/28900#discussion_r1424467194
##
airflow/models/dag.py:
##
@@ -1383,8 +1384,43 @@ def normalized_schedule_interval(self) ->
ScheduleInterval:
_schedule_interval = self.schedule_inte
dstandish commented on code in PR #28900:
URL: https://github.com/apache/airflow/pull/28900#discussion_r1423410165
##
airflow/models/dag.py:
##
@@ -1383,8 +1384,43 @@ def normalized_schedule_interval(self) ->
ScheduleInterval:
_schedule_interval = self.schedule_int