https://code.google.com/p/appengine-pipeline/wiki/GettingStarted#Execution_ordering
Log2Bq が完了した後に実行されるコールバック関数を追加しようとしました。しかし、私が使用しても動作しませpipeline.After
んpipeline.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())
}
)