Skip to content

feat: update fivetran connector with new sdk #13859

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

Merged

Conversation

yoonhyejin
Copy link
Collaborator

@yoonhyejin yoonhyejin commented Jun 25, 2025

  • updated fivetran connector with new dataflow / datajob SDK
  • updated datajob entity SDK to support finegrained lineage
  • fixed a small bug on datajob init

@github-actions github-actions bot added the ingestion PR or Issue related to the ingestion of metadata label Jun 25, 2025
@@ -134,7 +137,22 @@ def __init__(
self._setdefault_aspect(job_info)
self._ensure_datajob_props().flowUrn = str(flow.urn)

# Set properties if provided
self._init_basic_props(
Copy link
Collaborator Author

Choose a reason for hiding this comment

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

separated these to avoid mypy error (init is too complex)

Copy link
Collaborator

Choose a reason for hiding this comment

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

you can noqa: C901

@@ -103,12 +104,14 @@ def __init__(
ValueError: If neither flow nor (flow_urn and platform_instance) are provided
"""
if flow is None:
if flow_urn is None or platform_instance is None:
if flow_urn is None:
Copy link
Collaborator Author

Choose a reason for hiding this comment

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

fixed bug ; platform_instance is not strictly needed

@@ -237,21 +237,6 @@ def test_datajob_init_with_flow_urn() -> None:


def test_invalid_init() -> None:
flow = DataFlow(
Copy link
Collaborator Author

Choose a reason for hiding this comment

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

removed tests as we fixed bug above

flow_urn=datajob.flow_urn,
platform_instance=self.config.platform_instance,
name=datajob.name,
)
return DataProcessInstance.from_datajob(
Copy link
Collaborator Author

Choose a reason for hiding this comment

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

eh this is very hacky and i don't like this solution, but seems like we need to do a lot of job with api.entities.dataprocessinstance code to be compatible with the SDK v2. i'd rather just add DPI to SDK v2 rather than trying to make this compatible.

Copy link

codecov bot commented Jun 25, 2025

Bundle Report

Changes will increase total bundle size by 77 bytes (0.0%) ⬆️. This is within the configured threshold ✅

Detailed changes
Bundle name Size Change
datahub-react-web-esm 19.69MB 77 bytes (0.0%) ⬆️

Affected Assets, Files, and Routes:

view changes for bundle: datahub-react-web-esm

Assets Changed:

Asset Name Size Change Total Size Change (%)
assets/index-*.js 77 bytes 16.06MB 0.0%

Copy link

codecov bot commented Jun 25, 2025

Codecov Report

All modified and coverable lines are covered by tests ✅

📢 Thoughts on this report? Let us know!

@yoonhyejin yoonhyejin marked this pull request as ready for review June 26, 2025 10:31
@datahub-cyborg datahub-cyborg bot added the needs-review Label for PRs that need review from a maintainer. label Jun 26, 2025
"ownerTypes": {},
"lastModified": {
"time": 0,
"actor": "urn:li:corpuser:unknown"
Copy link
Collaborator Author

Choose a reason for hiding this comment

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

i'm not sure where this is coming from -- this should be corpuser:fivetran

@@ -134,7 +137,22 @@ def __init__(
self._setdefault_aspect(job_info)
self._ensure_datajob_props().flowUrn = str(flow.urn)

# Set properties if provided
self._init_basic_props(
Copy link
Collaborator

Choose a reason for hiding this comment

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

you can noqa: C901

@datahub-cyborg datahub-cyborg bot added pending-submitter-response Issue/request has been reviewed but requires a response from the submitter and removed needs-review Label for PRs that need review from a maintainer. labels Jun 26, 2025
@datahub-cyborg datahub-cyborg bot added needs-review Label for PRs that need review from a maintainer. and removed pending-submitter-response Issue/request has been reviewed but requires a response from the submitter labels Jun 27, 2025
@datahub-cyborg datahub-cyborg bot added pending-submitter-merge and removed needs-review Label for PRs that need review from a maintainer. labels Jun 30, 2025
@yoonhyejin yoonhyejin merged commit fedbfa3 into datahub-project:master Jul 2, 2025
63 of 66 checks passed
kartikey-visa pushed a commit to kartikey-visa/datahub that referenced this pull request Jul 23, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
ingestion PR or Issue related to the ingestion of metadata pending-submitter-merge
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants