私は Python Dataflow wordcount_minimal.py の例を実行していますが、正常に動作しています。
とにかく、私は今、Flaskビュー内からパイプラインを作成しようとしていますが、奇妙な理由ですべて失敗し続けています:
ImportError: Cannot re-init internal module __main__
これはdillパッケージによって発生します。具体的には次のとおりです。
https://github.com/uqfoundation/dill/blob/master/dill/dill.py#L67
新しい virtualenv の作成や、他の依存関係のない単純な Flask アプリの作成など、いくつかのテストを行いました。必要なパッケージはすべて次のとおりです。
Flask==0.11.1
google-cloud-dataflow
問題は解決しません。また、Dataflow Python SDK と dill パッケージ リポジトリの両方で、github の問題リストには何も見つかりませんでした。