Skip to content
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

Move fivetran sync provider code to this repo #33

Merged
merged 7 commits into from Jul 11, 2023

Conversation

pankajastro
Copy link
Contributor

@pankajastro pankajastro commented Jun 28, 2023

closes: #30

Move code from https://github.com/fivetran/airflow-provider-fivetran to this repo

Example DAG
Screenshot 2023-07-11 at 6 45 59 PM

  • Copy test

@pankajastro
Copy link
Contributor Author

Hi @phanikumv can please take a look to this PR?

@pankajastro pankajastro marked this pull request as ready for review June 30, 2023 13:46
Copy link
Contributor

@phanikumv phanikumv left a comment

Choose a reason for hiding this comment

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

I like the suggestion of merge it into one operator (on this repo) , but need to handle deprecation of Async class. There are existing users who use Async class.

fivetran_operator = FivetranOperator(
task_id="fivetran-operator",
fivetran_conn_id="fivetran_default",
connector_id="{{ var.value.connector_id }}",
Copy link
Contributor

Choose a reason for hiding this comment

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

Are we testing dags in CI? or AstroCloud?

Copy link
Contributor

Choose a reason for hiding this comment

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

manual testing is done on Astro cloud

Copy link
Contributor

Choose a reason for hiding this comment

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

we havent automated it

Copy link
Contributor Author

Choose a reason for hiding this comment

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

yes, we have manual testing. I have attached the dagrun screenshot

Copy link
Contributor

@sunank200 sunank200 left a comment

Choose a reason for hiding this comment

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

Tests are missing for the implementation

fivetran_provider_async/hooks.py Show resolved Hide resolved
fivetran_provider_async/operators.py Show resolved Hide resolved
Copy link
Contributor

@pankajkoti pankajkoti left a comment

Choose a reason for hiding this comment

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

Would be nice to review once operators are merged and tests are added.

fivetran_provider_async/operators.py Show resolved Hide resolved
@pankajastro
Copy link
Contributor Author

created a follow-up GH issue for depreciation and merging both operator/sensor #35

Co-authored-by: Ankit Chaurasia <8670962+sunank200@users.noreply.github.com>
@pankajastro pankajastro merged commit 3294955 into main Jul 11, 2023
5 checks passed
@pankajastro pankajastro deleted the remove_fivetran_deps branch July 11, 2023 13:57
@sunank200 sunank200 mentioned this pull request Jul 11, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Remove dependency on airflow-provider-fivetran
6 participants