Tuesday, 24 February 2026

Airflow - DAG Dependencies

  • Define the order in which tasks should run
  • Tasks can be upstream (run before) or downstream (run after)
  • Declared after creating the tasks
Methods to declare

  • Recommended
task1>>task2>>[task3,task4]
  • Alternative
task1.set_downstream(task2)
task3.set_upstream(task2)

at
Labels:

No comments:

Post a Comment

Subscribe to: Post Comments (Atom)

Airflow - DAG Dependencies

Define the order in which tasks should run Tasks can be upstream (run before) or downstream (run after) Declared after creating the tasks Me...

  • MD5 Function in INFORMATICA
    MD5 (Message Digest Function) is a hash function in Informatica which is used to evaluate data integrity. The MD5 function uses Message-Dig...
  • CACHING in Snowflake
    Result Cache Stores the results of a query (Cloud Services) Same queries can use that cache in the future Table data has not changed Micro-p...
  • SQL Error : Multiple ResultSets were returned by the query
    Upon using the custom query in the source object, the mapping fails with the following error: The select query for read operation failed bec...