-
Notifications
You must be signed in to change notification settings - Fork 16.4k
openlineage: add support for system tests, add support for example_bigquery_queries system test #31717
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
Conversation
e99a8fd to
fb98053
Compare
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 am wondering if this is the right place to keep OpenLineage system tests or should we have it in its own home tests/system/providers/openlineage/...? WDYT?
Wondering if some config disables OpenLineage or uses a different lineage backend then would having this here affect the system test run?
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.
+1
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 believe it's advantageous to have OL system tests as an addition to regular ones, because they are just an addition of one operator, and actively use rest of the dag.
Those aren't only "OpenLineage system tests" in vacuum, but test OL integration of this particular provider.
Having separate dags for system tests would result in fragmentation - we'd have to maintain the same dag, or at least subset of it, with just the addition of a single OpenLineageTestOperator.
However, I believe option to disable OpenLineage and make this special operator always pass is a very valid need, and will add such option.
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.
+1
fb98053 to
dd5f3d1
Compare
61718b5 to
351086a
Compare
351086a to
b61a13a
Compare
Signed-off-by: Maciej Obuchowski <obuchowski.maciej@gmail.com>
b61a13a to
25a95e1
Compare
|
Will reopen later |
The idea for system tests is as follows:
VariableTransportthat will push OpenLineage events toVariablewith key<DAG_ID>.<TASK_ID>.event.<EVENT_TYPE>.OpenLineageTestOperatorwill compare theexpectedevents with the ones that are stored in Variables.This PR adds those components, as well as OL support for
BigQueryGetDataOperatorand OL support for system test utilizing it.PR is based on previous PR: #31293 - only second commit is relevant to this PR.
Closes: #29676