Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Throw exception in DAG if status not 2xx #165

Open
1 task
anisbhsl opened this issue Jun 13, 2024 · 0 comments
Open
1 task

Throw exception in DAG if status not 2xx #165

anisbhsl opened this issue Jun 13, 2024 · 0 comments

Comments

@anisbhsl
Copy link
Contributor

This issue was encountered when we were trying to ingest fresh collections with veda_discover DAG. The DAG operation was a SUCCESS but no items were ingested by the ingestor API.

Further investigation through Cloudwatch logs revealed that the POST /ingestions endpoint was sending 422 response because it didn't have access to the S3 bucket it was supposed to have. This was ignored by airflow and it continued as a success.

Add an exception handler in airflow that fails the job if response status is other than the range of 2xx.

AC

  • Add exception handler to throw error if status is 4xx or 5xx
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant