-
Notifications
You must be signed in to change notification settings - Fork 13.7k
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
[OPENLINEAGE] Introduce AirflowJobFacet and AirflowStateRunFacet #39520
base: main
Are you sure you want to change the base?
Conversation
35778b2
to
ea6a570
Compare
ea6a570
to
d02af81
Compare
3d6af0d
to
7c0e499
Compare
77020dd
to
ec4bc16
Compare
I had to add some words to spelling wordlist, due to the docs error in CI here. Let me know if there is a better solution to that problem, but part of these words have already been present, just with different capitalization. |
if not dag_run.dag: | ||
return {} | ||
return { | ||
"airflowDag": AirflowJobFacet( |
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.
Any ideas for a better key than airflowDag
here ?
@mobuchowski @JDarDagran
ec4bc16
to
c57294d
Compare
I also added json specs for the facets, in a new directory. I was not sure if i should add the |
c57294d
to
8a86b29
Compare
44a2de1
to
c415d62
Compare
Signed-off-by: Kacper Muda <mudakacper@gmail.com>
c415d62
to
773637a
Compare
closes: #39467
^ Add meaningful description above
Read the Pull Request Guidelines for more information.
In case of fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
In case of a new dependency, check compliance with the ASF 3rd Party License Policy.
In case of backwards incompatible changes please leave a note in a newsfragment file, named
{pr_number}.significant.rst
or{issue_number}.significant.rst
, in newsfragments.