# Path: streamcorpus_pipeline/stages.py
# class Configured(object):
#     '''Any object containing a configuration.
# 
#     The configuration is passed to the constructor.
# 
#     .. attribute:: config
# 
#         The configuration dictionary for this object.
# 
#     '''
#     def __init__(self, config, *args, **kwargs):
#         super(Configured, self).__init__(*args, **kwargs)
#         self.config = config


import logging
from cStringIO import StringIO
from docx import Document
from zipfile import BadZipfile
from streamcorpus_pipeline.stages import Configured
from __future__ import absolute_import



logger = logging.getLogger(__name__)

def extract_text(data):
    fp = StringIO(data)

# Path: streamcorpus_pipeline/stages.py
# class Configured(object):
#     '''Any object containing a configuration.
# 
#     The configuration is passed to the constructor.
# 
#     .. attribute:: config
# 
#         The configuration dictionary for this object.
# 
#     '''
#     def __init__(self, config, *args, **kwargs):
#         super(Configured, self).__init__(*args, **kwargs)
#         self.config = config


# Path: streamcorpus_pipeline/_docx_to_text.py
import logging
from cStringIO import StringIO
from docx import Document
from zipfile import BadZipfile
from streamcorpus_pipeline.stages import Configured

from __future__ import absolute_import



logger = logging.getLogger(__name__)

def extract_text(data):
    fp = StringIO(data)

    document = Document(fp)