title: Python alternative to Java DataFlow Streaming code
body: <p>I have the following java code snippet which polls the gcs bucket for the arrival of new files. This is the code that I am using for my streaming pipeline, which would further load the data after applying some transformations into some destination.</p>
  <pre><code>PCollection&lt;String&gt; pcollection = pipeline.apply(&quot;Read From streaming source&quot;,
                  TextIO.read().from(&quot;gs://abc/xyz&quot;)
                          .watchForNewFiles(Duration.standardSeconds(10), Watch.Growth.never()));
  </code></pre>
  <p>but for a particular use case I need to achieve the same thing using python, for which I am unable to find the required libraries, also all the implementations for the streaming pipelines in python are for PubSub. Running the python pipeline with <code>streaming=true</code> doesn't solve any purpose as the code exits after completion and doesn't wait for new files. Can someone suggest a way to proceed?
  Thanks in advance.</p>