Skip to content

openlineage: add (S)FTP extractors#30888

Closed
mobuchowski wants to merge 2 commits intoapache:mainfrom
mobuchowski:openlineage-s-ftp-extractors
Closed

openlineage: add (S)FTP extractors#30888
mobuchowski wants to merge 2 commits intoapache:mainfrom
mobuchowski:openlineage-s-ftp-extractors

Conversation

@mobuchowski
Copy link
Contributor

This PR adds (S)FTP extractors to OpenLineage provider.

As rest of currently open extractor PRs, this depends on #30713, and will be rebased as soon as it's merged.

Signed-off-by: Maciej Obuchowski <obuchowski.maciej@gmail.com>
@mobuchowski mobuchowski force-pushed the openlineage-s-ftp-extractors branch 2 times, most recently from 93893d4 to 97e3b59 Compare May 8, 2023 15:39
Signed-off-by: Maciej Obuchowski <obuchowski.maciej@gmail.com>
@mobuchowski mobuchowski force-pushed the openlineage-s-ftp-extractors branch from 97e3b59 to 671d5f3 Compare May 8, 2023 15:56
Comment on lines +1224 to +1228
disable_source_code:
description: |
If disabled, OpenLineage events do not contain source code of particular
operators, like PythonOperator.
default: "True"
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Since this is disabled by default, I wonder if we should flip this into add_source_code.

Comment on lines +23 to +25
"""
:meta private:
"""
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Why is the __init__ file marked as private? Do we not want people to import from this file (but submodules instead?) and in that case, why are the classes re-exported from submodules into this file?

Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Because this is just temporary. The idea was that first extractors will be added "as is" and then they will be merged into operators. This is what @mobuchowski plan is. We will not release openlineage provider (it is currently excluded from release) until this refactoring is done.

Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The question then becomes why the imports are added to this file.

Comment on lines +28 to +30
"""
:meta private:
"""
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I believe the general advice is to put the module-level docstring above the imports instead of below.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants