Implement Control Flows (retries and Conditional Tasks Such as Branching and Looping) Using Lakeflow Jobs for Pipeline Orchestration DATA-ENGINEER-ASSOCIATE Practice Questions (Page 2)

Questions 6–10

1. 6application · medium

   A data engineering team uses Lakeflow Jobs to orchestrate a nightly pipeline. After the 'ingest' task completes, they need to run a 'validate' task. If validation fails, they want to run a 'notify' task that sends an alert to the data team. If validation succeeds, they want to proceed directly to the 'publish' task. Which Lakeflow Jobs feature should they use to implement this logic?

   • AA retry policy on the 'validate' task to retry until it succeeds.
   • BConditional branching based on the outcome of the 'validate' task.
   • CA loop that iterates over the 'validate' task until it succeeds.
   • DA single task that combines validation and notification logic.
   Reveal Solution Discussion Select an answer first
2. 7foundation · easy

   In Lakeflow Jobs, what is the purpose of conditional branching?

   • ATo run the same set of tasks repeatedly until a condition is met
   • BTo automatically retry failed tasks a specified number of times
   • CTo run all tasks in parallel regardless of dependencies
   • DTo execute different tasks based on the outcome of a previous task or an external condition
   Reveal Solution Discussion Select an answer first
4. 8expert · hard

   A data engineering team has a Lakeflow Jobs pipeline with a 'load' task that can succeed, fail, or be skipped. They want to run a 'reconcile' task only if the 'load' task succeeds, and a 'cleanup' task if the 'load' task fails or is skipped. Which configuration should they use?

   • ASet 'reconcile' as a dependent that runs on success, and 'cleanup' as a dependent that runs on failure only.
   • BUse a retry policy on 'load' to ensure it always succeeds, then run 'reconcile'.
   • CUse conditional branching on the 'load' task outcome: run 'reconcile' on success, and run 'cleanup' on failure or skip.
   • DUse a loop to run 'reconcile' and 'cleanup' for each possible outcome.
   Reveal Solution Discussion Select an answer first
5. 9foundation · easy

   What is the primary benefit of using a looping construct in a Lakeflow Jobs pipeline?

   • AIt ensures tasks run in parallel to reduce overall runtime.
   • BIt stops the pipeline if a task fails.
   • CIt automatically retries failed tasks until they succeed.
   • DIt reduces the need to manually define a separate task for each item in a collection.
   Reveal Solution Discussion Select an answer first
6. 10foundation · easy

   A Lakeflow Jobs task sometimes fails with a specific exit code that indicates a transient issue, but other exit codes indicate permanent failures. Which feature allows the task to be retried only for that specific exit code?

   • ATask timeout
   • BJob schedule
   • CRetry conditions
   • DTask dependencies
   Reveal Solution Discussion Select an answer first