Skip to content

Commit

Permalink
Final rename
Browse files Browse the repository at this point in the history
  • Loading branch information
danielvdende committed Mar 15, 2022
1 parent f5702f8 commit 283cfa1
Show file tree
Hide file tree
Showing 15 changed files with 24 additions and 22 deletions.
4 changes: 3 additions & 1 deletion .github/workflows/release.yml
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
name: Relase new version
on: release
on:
release:
types: [published]
jobs:
release:
runs-on: ubuntu-latest
Expand Down
4 changes: 2 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
# PyADF
PyADF aims to make developers lives easier by wrapping the Azure Data Factory Python SDK with an intuitive, powerful, and easy to use API that hopefully will remind people of working with Apache Airflow ;-).
# adfpy
adfpy aims to make developers lives easier by wrapping the Azure Data Factory Python SDK with an intuitive, powerful, and easy to use API that hopefully will remind people of working with Apache Airflow ;-).

File renamed without changes.
File renamed without changes.
4 changes: 2 additions & 2 deletions pyadf/activities/control.py → adfpy/activities/control.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,8 +10,8 @@
SetVariableActivity,
)

from pyadf.activity import AdfActivity
from pyadf.pipeline import AdfPipeline
from adfpy.activity import AdfActivity
from adfpy.pipeline import AdfPipeline


class AdfExecutePipelineActivity(AdfActivity):
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
SqlServerStoredProcedureActivity,
)

from pyadf.activity import AdfActivity
from adfpy.activity import AdfActivity


class AdfCopyActivity(AdfActivity):
Expand Down
File renamed without changes.
2 changes: 1 addition & 1 deletion pyadf/pipeline.py → adfpy/pipeline.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

from azure.mgmt.datafactory.models import PipelineResource

from pyadf.activity import AdfActivity
from adfpy.activity import AdfActivity


class AdfPipeline:
Expand Down
4 changes: 2 additions & 2 deletions deploy.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
from azure.mgmt.datafactory import DataFactoryManagementClient
from azure.mgmt.resource import ResourceManagementClient

from pyadf.pipeline import AdfPipeline
from adfpy.pipeline import AdfPipeline

subscription_id = "5ddf05c0-b972-44ca-b90a-3e49b5de80dd"
rg_name = "daniel-playground"
Expand All @@ -20,7 +20,7 @@
resource_client = ResourceManagementClient(credentials, subscription_id)
adf_client = DataFactoryManagementClient(credentials, subscription_id)

adf_pipelines_path = Path("/Users/daniel/code/opensource/pyadf/examples/")
adf_pipelines_path = Path("/Users/daniel/code/opensource/adfpy/examples/")

# 1. fetch existing pipelines from ADF
existing_pipelines = [
Expand Down
6 changes: 3 additions & 3 deletions examples/complex_extraction_ingestion_flow/main.py
Original file line number Diff line number Diff line change
@@ -1,18 +1,18 @@
# TODO: we should abstract this away, it's not nice to have to deal with these models
from azure.mgmt.datafactory.models import BlobSource, BlobSink

from pyadf.activities.control import (
from adfpy.activities.control import (
AdfExecutePipelineActivity,
AdfIfConditionActivity,
AdfForEachActivity,
AdfSetVariableActivity,
)
from pyadf.activities.execution import (
from adfpy.activities.execution import (
AdfCopyActivity,
AdfDeleteActivity,
AdfDatabricksSparkPythonActivity,
)
from pyadf.pipeline import AdfPipeline
from adfpy.pipeline import AdfPipeline
from examples.complex_extraction_ingestion_flow.no_watermark_pipeline import (
no_watermark_pipeline,
)
Expand Down
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
from azure.mgmt.datafactory.models import BlobSource, BlobSink


from pyadf.activities.control import AdfSetVariableActivity
from pyadf.activities.execution import AdfCopyActivity
from pyadf.pipeline import AdfPipeline
from adfpy.activities.control import AdfSetVariableActivity
from adfpy.activities.execution import AdfCopyActivity
from adfpy.pipeline import AdfPipeline

no_watermark_pipeline = AdfPipeline(
name="complex_extraction_ingestion_flow_no_watermark",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,13 +1,13 @@
from azure.mgmt.datafactory.models import BlobSource, BlobSink


from pyadf.activities.control import AdfSetVariableActivity, AdfIfConditionActivity
from pyadf.activities.execution import (
from adfpy.activities.control import AdfSetVariableActivity, AdfIfConditionActivity
from adfpy.activities.execution import (
AdfCopyActivity,
AdfLookupActivity,
AdfSqlServerStoredProcedureActivity,
)
from pyadf.pipeline import AdfPipeline
from adfpy.pipeline import AdfPipeline

watermark_pipeline = AdfPipeline(
name="complex_extraction_ingestion_flow_watermark",
Expand Down
4 changes: 2 additions & 2 deletions examples/simple_copy_pipeline/main.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
from azure.mgmt.datafactory.models import BlobSource, BlobSink

from pyadf.activities.execution import AdfCopyActivity, AdfDatabricksSparkPythonActivity
from pyadf.pipeline import AdfPipeline
from adfpy.activities.execution import AdfCopyActivity, AdfDatabricksSparkPythonActivity
from adfpy.pipeline import AdfPipeline

extract = AdfCopyActivity(
name="copyBlobToBlob",
Expand Down
2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
[tool.poetry]
name = "pyadf"
name = "adfpy"
version = "0.0.0"
description = "A Pythonic wrapper for Azure Data Factory"
authors = ["Daniel van der Ende <[email protected]>"]
Expand Down
2 changes: 1 addition & 1 deletion tests/activities/test_control.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
from pyadf.activities import control as victim
from adfpy.activities import control as victim

from azure.mgmt.datafactory.models import ForEachActivity, SetVariableActivity, Expression, ActivityDependency

Expand Down

0 comments on commit 283cfa1

Please sign in to comment.