o-nikolas commented on code in PR #28161:
URL: https://github.com/apache/airflow/pull/28161#discussion_r1095134144
##
airflow/executors/kubernetes_executor.py:
##
@@ -773,6 +775,57 @@ def _change_state(self, key: TaskInstanceKey, state: str |
None, pod_id: str, na
o-nikolas commented on code in PR #28161:
URL: https://github.com/apache/airflow/pull/28161#discussion_r1065010894
##
airflow/executors/kubernetes_executor.py:
##
@@ -749,6 +751,57 @@ def _change_state(self, key: TaskInstanceKey, state: str |
None, pod_id: str, na
o-nikolas commented on code in PR #28161:
URL: https://github.com/apache/airflow/pull/28161#discussion_r1064208434
##
airflow/executors/kubernetes_executor.py:
##
@@ -749,6 +751,57 @@ def _change_state(self, key: TaskInstanceKey, state: str |
None, pod_id: str, na
o-nikolas commented on code in PR #28161:
URL: https://github.com/apache/airflow/pull/28161#discussion_r1049219335
##
airflow/executors/base_executor.py:
##
@@ -304,6 +304,9 @@ def execute_async(
"""
raise NotImplementedError()
+def get_task_log(self,
