DEA-C02 · Question #87
A Data Engineer needs to monitor a continuous data pipeline that is processing data. The data is ingested into Snowflake using a pipe from an Amazon S3 bucket, then it is transformed using a series of
The correct answer is D. Create a queue notification integration error and assign it to this root task:. In Snowflake, task-level error notifications require a notification integration of queue type (connecting to a cloud messaging service such as AWS SNS/SQS, Azure Event Hub, or GCP Pub/Sub), which is then assigned to the root task via the ERROR_INTEGRATION parameter - this is exac
Question
A Data Engineer needs to monitor a continuous data pipeline that is processing data. The data is ingested into Snowflake using a pipe from an Amazon S3 bucket, then it is transformed using a series of tasks and streams. The pipeline provides notifications if there is a failure during data importation. How should the Engineer add a notification signaling that there is a failure of a task involved with data transformations?
Options
- ACreate a queue-type error integration and assign it to this root task:
- BCreate a Snowflake alert and assign it to this root task:
- CCreate an email notification and assign it to this root task:
- DCreate a queue notification integration error and assign it to this root task:
How the community answered
(26 responses)- A8% (2)
- B15% (4)
- C4% (1)
- D73% (19)
Explanation
In Snowflake, task-level error notifications require a notification integration of queue type (connecting to a cloud messaging service such as AWS SNS/SQS, Azure Event Hub, or GCP Pub/Sub), which is then assigned to the root task via the ERROR_INTEGRATION parameter - this is exactly what option D describes.
Why the others are wrong:
- A uses the term "error integration," which does not exist in Snowflake; the correct object type is a notification integration - A is simply mislabeled.
- B is wrong because Snowflake Alerts monitor SQL-defined conditions on a schedule; they are not designed to capture task execution failures triggered by the task DAG engine.
- C is wrong because native email is not a supported delivery mechanism for task
ERROR_INTEGRATION; email notifications exist for Snowflake Alerts, not for task error integrations.
Memory tip: Remember the property name - ERROR_INTEGRATION takes a notification integration, not an "error integration." If you see "error integration" as a standalone object type (option A), it's a trap - Snowflake only has NOTIFICATION INTEGRATION. Queue = cloud messaging service = the correct delivery channel for task failures.
Topics
Community Discussion
No community discussion yet for this question.