Bas Harenslak questions

Bas Harenslak answers

• How to run Scala code in Airflow using Scala Operator
• How to get execution_date as epoch time?
• Access "params" in body of dag
• Branching in Apache Airflow using TaskFlowAPI
• How to pass the PostgreSQL query result into a variable in Airflow? (Postgres Operator or Postgres Hook)
• DAG marked as "success" if one task fails, because of trigger rule ALL_DONE
• Airflow how to get env vars of each dag from the code itself