diff --git a/airflow/utils/log/file_task_handler.py b/airflow/utils/log/file_task_handler.py index 111f26c279cf0..c1c32658a164a 100644 --- a/airflow/utils/log/file_task_handler.py +++ b/airflow/utils/log/file_task_handler.py @@ -52,7 +52,7 @@ def set_context(self, ti): :param ti: task instance object """ local_loc = self._init_file(ti) - self.handler = logging.FileHandler(local_loc) + self.handler = logging.FileHandler(local_loc, encoding='utf-8') self.handler.setFormatter(self.formatter) self.handler.setLevel(self.level)