

def __exit__(self, exception_type, exception_value, traceback):
    self._file.close()
    if hasattr(self, 'temp_path'):
        _gcs_file_copy(self.temp_path, self.sink.file_path, 'text/plain')

dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/io/fileio.py TextFileWriter.__exit__/original