-
Notifications
You must be signed in to change notification settings - Fork 4
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
feat: FIR-42244 airflow allow passing query timeout #44
feat: FIR-42244 airflow allow passing query timeout #44
Conversation
@@ -137,6 +143,8 @@ def __init__( | |||
self.firebolt_conn_id = firebolt_conn_id | |||
self.engine_name = engine_name | |||
self.database = None | |||
self.query_timeout = None | |||
self.fail_on_query_timeout = False |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Should this be True
by default?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think it doesn't matter since we won't support engine start/stop timeout here so it will not be accounted for. I can set it to true
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let's set it to true just to avoid confusion, users might see it and have questions why can't they fail if something goes wrong. If there's any timeout behind the scenes (e.g. network disconnect or something) we'll propagate it.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
otherwise lgtm
Quality Gate failedFailed conditions |
Added ability to pass timeout to firebolt operator and hook