PythonのAppEngineのMapReduceの

Question

私はかなり簡単なMapReduceのパイプラインを作成しているが、私は不可解持っています：私はそれを起動しようとすると

PipelineSetupError: Error starting production.cron.pipelines.ItemsInfoPipeline(*(), **{})#a741186284ed4fb8a4cd06e38921beff:

を。もちろん

class ItemsInfoPipeline(base_handler.PipelineBase): 
""" 
""" 

    def run(self): 
     output = yield mapreduce_pipeline.MapreducePipeline(
      job_name="items_job", 
      mapper_spec="production.cron.mappers.items_info_mapper", 
      input_reader_spec="mapreduce.input_readers.DatastoreInputReader", 
      mapper_params={ 
       "input_reader": { 
        "entity_kind": "production.models.Transaction" 
       } 
      } 
     ) 

     yield ItemsInfoStorePipeline(output) 


class ItemsInfoStorePipeline(base_handler.PipelineBase): 
""" 
""" 

    def run(self, statistics): 
     print statistics 
     return "OK" 

私はパイプラインが開始されている焦点を当てていますので、私は二重のマッパー・パスが正しいことを確認し、ItemsInfoStorePipelineは何もしていません考慮している、起きていない。これは、パイプラインのコードです。

すべて、フラスコビューによってトリガ以下の通りです：

class ItemsInfoMRJob(views.MethodView): 
""" 

It's based on transacions. 

""" 

    def get(self): 
    """ 

    :return: 
    """ 
     pipeline = ItemsInfoPipeline() 
     pipeline.start() 

     redirect_url = "%s/status?root=%s" % (pipeline.base_path, pipeline.pipeline_id) 

     return flask.redirect(redirect_url) 

私は任意の助け​​

感謝を使用しています。

UPDATE

上記のコードは、一度展開働きます。

UPDATE 2

は、どうやらこれに対処より多くの人々があります：私はこれを更新しています

https://github.com/GoogleCloudPlatform/appengine-mapreduce/issues/103

Answer 1

。私はパイプラインを使っているコードベースを持っていて、OSXでうまく動作します。

はProtoRPCのメソッドの実装から予期しないエラーが発生しました：私は単に私が何も彼はこれを取得する、それが働いて取得するようだOSXを使用して他の開発者だったPipelineSetupError

私の周りのバージョンを交換しようとしたのとPCのマッチを完璧にして、それは起こり続ける。私は最終的に崩壊し、ドッカーにUbuntuのイメージを構築しました。 AppEngineのバージョンとライブラリを完全に一致させるために最善を尽くしています。

また、同じメッセージで開始することも拒否します。私は、エラーを飲み込んでいる部分のコメントを外してライブラリの作業を始めました。しかし、それは、ウサギの長い穴でした。それ以上のものは、何が起こっているのかを呑み込んでいるようです。