Как получить временную метку в kwargs, например, run_id в Airflow?

Question

Как мы получаем run_id в потоке воздуха, как получить метку времени (ts)?

Answer 1

Первый: в вашей задаче установлен provide_context = True

bye_operator = PythonOperator(
  task_id='bye_task',
  python_callable=print_goodbye,
  provide_context=True,
  dag=dag
)

Второй: убедитесь, что вы передаете известные аргументы в функцию обратного вызова:

def print_goodbye(**kwargs):
    ts = kwargs.get('ts', None)
    print(ts)
    return 'Good bye world!'