SlackAPIPostOperatorで `ds`を取得するにはどうしたらいいですか？

Question

私はdatetime paramを必要とするPythonスクリプトを実行し、その出力を余裕を持って残したいと思っています。しかし、気流テンプレート変数dsを取得する方法がわかりません。

私はコードの下に持っている、のは、言ってみましょう：

def make_txt(): 
    # get ds 
    ds = get_ds() 
    ds = ds * 3 + 4/5 # do something with ds 
    return ds 

slack_task = SlackAPIPostOperator(
    text=make_txt(), 
    token='xoxp-xxxxxxx', 
) 

私はairflow backfill dag_id -s 2016-10-01で実行されますので

、 dsは（ここでは2016年10月1日である）テキストをたるみに渡す必要があります。

私は、ファイルにpythonスクリプトの出力を書き込んだ後、それを読んで、直接テキストをスラックに渡そうとします。しかし、私はそれが完璧な解決策だとは思わない。

Answer 1

textフィールドがSlackAPIPostOperatorでテンプレート化されているため、テキスト内に{{ ds }}を追加すると、jinjaによって挿入されます。