Skip to content

Commit

Permalink
[dagster-fivetran] Fivetran managed elements implementation (#10543)
Browse files Browse the repository at this point in the history
* [dagster-fivetran] Fivetran managed elements implementation

* fix tox

* lint

* mypy

* unused import

* rm print

* add cli
  • Loading branch information
benpankow committed Dec 1, 2022
1 parent 0e0b602 commit 0589112
Show file tree
Hide file tree
Showing 9 changed files with 953 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,15 @@
from .types import FivetranOutput
from .version import __version__

try:
import dagster_managed_elements

from .managed import FivetranConnector, FivetranDestination, FivetranManagedElementReconciler

except ImportError:
pass


check_dagster_package_version("dagster-fivetran", __version__)

__all__ = [
Expand Down
20 changes: 20 additions & 0 deletions python_modules/libraries/dagster-fivetran/dagster_fivetran/cli.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,20 @@
import click

try:
from dagster_managed_elements.cli import apply_cmd, check_cmd

@click.group()
def main():
pass

main.add_command(check_cmd)
main.add_command(apply_cmd)


except ImportError:

@click.group(
help="In order to use managed Fivetran config, the dagster-managed-elements package must be installed."
)
def main():
pass
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
from .reconciliation import FivetranManagedElementReconciler
from .types import FivetranConnector, FivetranDestination

0 comments on commit 0589112

Please sign in to comment.