[CP][AIRFLOW-3121] Define closed property on StreamLogWriter (apache#…

…3955) (apache#52)

CP of 2d5b8a5

airflow/utils/log/logging_mixin.py

@@ -68,6 +68,7 @@ def _set_context(self, context):
             set_context(self.log, context)
 
 
+# TODO: Formally inherit from io.IOBase
 class StreamLogWriter(object):
     encoding = False
 
@@ -83,6 +84,16 @@ def __init__(self, logger, level):
         self.level = level
         self._buffer = str()
 
+    @property
+    def closed(self):
+        """
+        Returns False to indicate that the stream is not closed (as it will be
+        open for the duration of Airflow's lifecycle).
+
+        For compatibility with the io.IOBase interface.
+        """
+        return False
+
     def write(self, message):
         """
         Do whatever it takes to actually log the specified logging record

airflow/version.py

@@ -18,5 +18,5 @@
 # under the License.
 #
 
-version = '1.10.4+twtr11'
+version = '1.10.4+twtr12'