title: Unable to use CsvFileSource from beam_utils.sources in apache beam program on Cloud Dataflow
body: <p>Unable to import CsvFileSource but able to install beam_utils.</p>
  
  <p>I need this import to run the Cloud data flow program.</p>
  
  <p>Code has -</p>
  
  <pre><code>from beam_utils.sources import CsvFileSource
  </code></pre>
  
  <p>Error message :</p>
  
  <pre><code>&gt;&gt;&gt; from beam_utils.sources import CsvFileSource
  Traceback (most recent call last):
    File "&lt;stdin&gt;", line 1, in &lt;module&gt;
    File "/home/vk/.local/lib/python2.7/site-packages/beam_utils/sources.py", line 14, in &lt;module&gt;
      class JsonLinesFileSource(beam.io.filebasedsource.FileBasedSource):
    File "/home/vk/.local/lib/python2.7/site-packages/beam_utils/sources.py", line 17, in JsonLinesFileSource
      compression_type=fileio.CompressionTypes.AUTO,
  AttributeError: 'module' object has no attribute 'CompressionTypes'
  &gt;&gt;&gt;
  </code></pre>
  
  <p>I even tried import using python3.
  any idea, how I can bypass.</p>