vchiapaikeo commented on code in PR #35536:
URL: https://github.com/apache/airflow/pull/35536#discussion_r1448975634
##########
airflow/utils/log/file_task_handler.py:
##########
@@ -357,7 +367,9 @@ def _read(
worker_log_full_path = Path(self.local_base, worker_log_rel_path)
local_messages, local_logs =
self._read_from_local(worker_log_full_path)
messages_list.extend(local_messages)
- if is_running and not executor_messages:
+ if ti.task.inherits_from_empty_operator is True and self._test_mode is
False:
Review Comment:
Okay, modified my approach here to catch the exception instead which is much
less disruptive to tests. Retested manually as well and all continues to look
good -
<img width="1470" alt="Screenshot 2024-01-11 at 9 44 50 AM"
src="https://github.com/apache/airflow/assets/9200263/81b36557-4841-45ae-b8c0-f6d7c3563d8d";>
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
