Jak se dostat run id a dát ji do proměnné v proudění Vzduchu

Question 1

Chci se dostat run_id provedených DAG a zacházet s ní jako proměnnou DAG sám. Je tam funkce?

with DAG(
    dag_id='question',
    ...
) as dag:
    
    question = PythonOperator(
        task_id='question_python',
        python_callable=question_python,
        op_kwargs={run_id:#here },
    )

Question 2

Není třeba používat op_kwargs tady. run_id je makro poskytována proudění Vzduchu tak je to k dispozici v rámci python disponibilní:

def question_python(run_id, **context):
    # your function code

nebo

def question_python(**context):
    run_id = context[run_id]
    # your function code

Pokud používáte proudění Vzduchu < 2.0: Budete potřebovat také přidat provide_context=True na váš PythonOperator

Elad · Answer 1 · 2021-11-20T08:33:28

Není třeba používat op_kwargs tady. run_id je makro poskytována proudění Vzduchu tak je to k dispozici v rámci python disponibilní:

def question_python(run_id, **context):
    # your function code

nebo

def question_python(**context):
    run_id = context[run_id]
    # your function code

Pokud používáte proudění Vzduchu < 2.0: Budete potřebovat také přidat provide_context=True na váš PythonOperator

Jak se dostat run id a dát ji do proměnné v proudění Vzduchu

Otázka

Nejlepší odpověď

V jiných jazycích

Tato stránka je v jiných jazycích

Populární v této kategorii

Oblíbené položky v této kategorii