0

https://code.google.com/p/appengine-pipeline/wiki/GettingStarted#Execution_ordering

Log2Bq が完了した後に実行されるコールバック関数を追加しようとしました。しかし、私が使用しても動作しませpipeline.Afterpipeline.InOrder。次のコード サンプルでは、​​タスクキューは Log2Bq を待たずにすぐに実行されます。この問題を解決するには、実行順序を機能させるために、タスクキューを保持する別のパイプラインを作成する必要がありますか?

class Log2Stat(base_handler.PipelineBase):
    def run(self, _date):
        print "start track"
        with pipeline.InOrder():
            yield pipelines.Log2Bq()

            print "finish track"
            taskqueue.add(
                url='/worker/update_daily_stat',
                params={
                    "date": str(_date.date())
                }
            )
4

1 に答える 1