Skip to content

Commit

Permalink
[AIRFLOW-3121] Define closed property on StreamLogWriter (apache#3955)
Browse files Browse the repository at this point in the history
[AIRFLOW-3121] Define closed property on StreamLogWriter
  • Loading branch information
jinnovation authored and aoen committed Oct 16, 2018
1 parent 74c613b commit 2d5b8a5
Showing 1 changed file with 11 additions and 0 deletions.
11 changes: 11 additions & 0 deletions airflow/utils/log/logging_mixin.py
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand All @@ -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
Expand Down

0 comments on commit 2d5b8a5

Please sign in to comment.